K8s源码分析(22)-client go组件之clientset

// staging/src/k8s.io/client-go/kubernetes/clientset.go
type Interface interface {
  Discovery() discovery.DiscoveryInterface
  AdmissionregistrationV1() admissionregistrationv1.AdmissionregistrationV1Interface
  AdmissionregistrationV1beta1() admissionregistrationv1beta1.AdmissionregistrationV1beta1Interface
  InternalV1alpha1() internalv1alpha1.InternalV1alpha1Interface
  AppsV1() appsv1.AppsV1Interface
  AppsV1beta1() appsv1beta1.AppsV1beta1Interface
  AppsV1beta2() appsv1beta2.AppsV1beta2Interface
  ......
}

type Clientset struct {
  *discovery.DiscoveryClient
  admissionregistrationV1      *admissionregistrationv1.AdmissionregistrationV1Client
  admissionregistrationV1beta1 *admissionregistrationv1beta1.AdmissionregistrationV1beta1Client
  internalV1alpha1             *internalv1alpha1.InternalV1alpha1Client
  appsV1                       *appsv1.AppsV1Client
  appsV1beta1                  *appsv1beta1.AppsV1beta1Client
  appsV1beta2                  *appsv1beta2.AppsV1beta2Client
  ......
}

func (c *Clientset) AppsV1() appsv1.AppsV1Interface {
  return c.appsV1
}

func (c *Clientset) AppsV1beta1() appsv1beta1.AppsV1beta1Interface {
  return c.appsV1beta1
}

func (c *Clientset) AppsV1beta2() appsv1beta2.AppsV1beta2Interface {
  return c.appsV1beta2
}

// staging/src/k8s.io/client-go/kubernetes/clientset.go
func NewForConfig(c *rest.Config) (*Clientset, error) {
  configShallowCopy := *c
  if configShallowCopy.RateLimiter == nil && configShallowCopy.QPS > 0 {
    if configShallowCopy.Burst <= 0 {
      return nil, fmt.Errorf("burst is required to be greater than 0 when RateLimiter is not set and QPS is set to greater than 0")
    }
    configShallowCopy.RateLimiter = flowcontrol.NewTokenBucketRateLimiter(configShallowCopy.QPS, configShallowCopy.Burst)
  }
  var cs Clientset
  var err error
  cs.admissionregistrationV1, err = admissionregistrationv1.NewForConfig(&configShallowCopy)
  if err != nil {
    return nil, err
  }
  cs.admissionregistrationV1beta1, err = admissionregistrationv1beta1.NewForConfig(&configShallowCopy)
  if err != nil {
    return nil, err
  }
  cs.internalV1alpha1, err = internalv1alpha1.NewForConfig(&configShallowCopy)
  if err != nil {
    return nil, err
  }
  cs.appsV1, err = appsv1.NewForConfig(&configShallowCopy)
  if err != nil {
    return nil, err
  }
  cs.appsV1beta1, err = appsv1beta1.NewForConfig(&configShallowCopy)
  if err != nil {
    return nil, err
  }
  cs.appsV1beta2, err = appsv1beta2.NewForConfig(&configShallowCopy)
  if err != nil {
    return nil, err
  }
  ......
  return &cs, nil
}