Custom Controller 之 Informer(二)

    !FILENAME informers/generic.go:58

    !FILENAME informers/factory.go:185

    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

    从 apps.Interface 一路到 DeploymentInformer

    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 {
    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

    deploymentInformer

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

    1. type deploymentInformer struct {
    2.    factory          internalinterfaces.SharedInformerFactory
    3.    tweakListOptions internalinterfaces.TweakListOptionsFunc
    4.    namespace        string
    5. }
    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())

    !FILENAME informers/factory.go:53

    1. type sharedInformerFactory struct {
    2.    client           kubernetes.Interface
    3.    namespace        string
    4.    tweakListOptions internalinterfaces.TweakListOptionsFunc
    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

    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