Custom Controller 之 Informer(二)

In Edit

概述

GenericInformer

!FILENAME informers/generic.go:58

  1. type GenericInformer interface {
  2.    Informer() cache.SharedIndexInformer
  3.    Lister() cache.GenericLister
  4. }
  6. type genericInformer struct {
  7.    informer cache.SharedIndexInformer
  8.    resource schema.GroupResource
  9. }

SharedIndexInformer

GenericLister

SharedInformerFactory

!FILENAME informers/factory.go:185

  1. type SharedInformerFactory interface {
  2.    internalinterfaces.SharedInformerFactory
  3.    ForResource(resource schema.GroupVersionResource) (GenericInformer, error)
  4.    WaitForCacheSync(stopCh <-chan struct{}) map[reflect.Type]bool
  6.    Admissionregistration() admissionregistration.Interface
  7.    Apps() apps.Interface
  8.    Auditregistration() auditregistration.Interface
  9.    Autoscaling() autoscaling.Interface
  10.    Batch() batch.Interface
  11.    Certificates() certificates.Interface
  12.    Coordination() coordination.Interface
  13.    Core() core.Interface
  14.    Events() events.Interface
  15.    Extensions() extensions.Interface
  16.    Networking() networking.Interface
  17.    Policy() policy.Interface
  18.    Rbac() rbac.Interface
  19.    Scheduling() scheduling.Interface
  20.    Settings() settings.Interface
  21.    Storage() storage.Interface
  22. }

apps.Interface

1556211911682

从 apps.Interface 一路到 DeploymentInformer

!FILENAME informers/apps/interface.go:29

  1. type Interface interface {
  2.    // V1 provides access to shared informers for resources in V1.
  3.    V1() v1.Interface
  4.    // V1beta1 provides access to shared informers for resources in V1beta1.
  5.    V1beta1() v1beta1.Interface
  6.    // V1beta2 provides access to shared informers for resources in V1beta2.
  7.    V1beta2() v1beta2.Interface
  8. }

v1.Interface

!FILENAME informers/apps/v1/interface.go:26

  1. type Interface interface {
  2.    // ControllerRevisions returns a ControllerRevisionInformer.
  3.    ControllerRevisions() ControllerRevisionInformer
  4.    // DaemonSets returns a DaemonSetInformer.
  5.    DaemonSets() DaemonSetInformer
  6.    // Deployments returns a DeploymentInformer.
  7.    Deployments() DeploymentInformer
  8.    // ReplicaSets returns a ReplicaSetInformer.
  9.    ReplicaSets() ReplicaSetInformer
  10.    // StatefulSets returns a StatefulSetInformer.
  11.    StatefulSets() StatefulSetInformer
  12. }

DeploymentInformer

!FILENAME informers/apps/v1/deployment.go:36

  1. type DeploymentInformer interface {
  2.    Informer() cache.SharedIndexInformer
  3.    Lister() v1.DeploymentLister
  4. }

deploymentInformer

!FILENAME informers/apps/v1/deployment.go:41

  1. type deploymentInformer struct {
  2.    factory          internalinterfaces.SharedInformerFactory
  3.    tweakListOptions internalinterfaces.TweakListOptionsFunc
  4.    namespace        string
  5. }

!FILENAME informers/apps/v1/deployment.go:79

  1. func (f *deploymentInformer) defaultInformer(client kubernetes.Interface, resyncPeriod time.Duration) cache.SharedIndexInformer {
  2.     return NewFilteredDeploymentInformer(client, f.namespace, resyncPeriod, cache.Indexers{cache.NamespaceIndex: cache.MetaNamespaceIndexFunc}, f.tweakListOptions)
  3. }
  5. func (f *deploymentInformer) Informer() cache.SharedIndexInformer {
  6.    return f.factory.InformerFor(&appsv1.Deployment{}, f.defaultInformer)
  7. }
  9. func (f *deploymentInformer) Lister() v1.DeploymentLister {
  10.    return v1.NewDeploymentLister(f.Informer().GetIndexer())
  11. }

sharedInformerFactory

!FILENAME informers/factory.go:53

  1. type sharedInformerFactory struct {
  2.    client           kubernetes.Interface
  3.    namespace        string
  4.    tweakListOptions internalinterfaces.TweakListOptionsFunc
  5.    lock             sync.Mutex
  6.    defaultResync    time.Duration
  7.    customResync     map[reflect.Type]time.Duration
  9.    informers map[reflect.Type]cache.SharedIndexInformer
  10.    // startedInformers is used for tracking which informers have been started.
  11.    // This allows Start() to be called multiple times safely.
  12.    startedInformers map[reflect.Type]bool
  13. }

kubernetes.Interface

1556213817097

Clientset

  1. type Clientset struct {
  2.    *discovery.DiscoveryClient
  3.    admissionregistrationV1alpha1 *admissionregistrationv1alpha1.AdmissionregistrationV1alpha1Client
  4.    admissionregistrationV1beta1  *admissionregistrationv1beta1.AdmissionregistrationV1beta1Client
  5.    appsV1beta1                   *appsv1beta1.AppsV1beta1Client
  6.    appsV1beta2                   *appsv1beta2.AppsV1beta2Client
  7.    appsV1                        *appsv1.AppsV1Client
  8.    // ……
  9.    coreV1                        *corev1.CoreV1Client
  10.    eventsV1beta1                 *eventsv1beta1.EventsV1beta1Client
  11.    extensionsV1beta1             *extensionsv1beta1.ExtensionsV1beta1Client
  12.    // ……
  13. }

appsv1.AppsV1Client

!FILENAME kubernetes/typed/apps/v1/apps_client.go:38

  1. type AppsV1Client struct {
  2.    restClient rest.Interface
  3. }

rest.Interface

  1. type Interface interface {
  2.    GetRateLimiter() flowcontrol.RateLimiter
  3.    Verb(verb string) *Request
  4.    Post() *Request
  5.    Put() *Request
  6.    Patch(pt types.PatchType) *Request
  7.    Get() *Request
  8.    Delete() *Request
  9.    APIVersion() schema.GroupVersion
  10. }

RESTClient

!FILENAME rest/client.go:61

  1. type RESTClient struct {
  2.    // base is the root URL for all invocations of the client
  3.    base *url.URL
  4.    versionedAPIPath string
  5.    contentConfig ContentConfig
  6.    serializers Serializers
  7.    createBackoffMgr func() BackoffManager
  8.    Throttle flowcontrol.RateLimiter
  9.    Client *http.Client
  10. }