// NewDynamicSharedInformerFactory constructs a new instance of dynamicSharedInformerFactory for all namespaces. func NewDynamicSharedInformerFactory(client dynamic.Interface, defaultResync time.Duration) DynamicSharedInformerFactory { … } // NewFilteredDynamicSharedInformerFactory constructs a new instance of dynamicSharedInformerFactory. // Listers obtained via this factory will be subject to the same filters as specified here. func NewFilteredDynamicSharedInformerFactory(client dynamic.Interface, defaultResync time.Duration, namespace string, tweakListOptions TweakListOptionsFunc) DynamicSharedInformerFactory { … } type dynamicSharedInformerFactory … var _ … func (f *dynamicSharedInformerFactory) ForResource(gvr schema.GroupVersionResource) informers.GenericInformer { … } // Start initializes all requested informers. func (f *dynamicSharedInformerFactory) Start(stopCh <-chan struct{ … } // WaitForCacheSync waits for all started informers' cache were synced. func (f *dynamicSharedInformerFactory) WaitForCacheSync(stopCh <-chan struct{ … } func (f *dynamicSharedInformerFactory) Shutdown() { … } // NewFilteredDynamicInformer constructs a new informer for a dynamic type. func NewFilteredDynamicInformer(client dynamic.Interface, gvr schema.GroupVersionResource, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions TweakListOptionsFunc) informers.GenericInformer { … } type dynamicInformer … var _ … func (d *dynamicInformer) Informer() cache.SharedIndexInformer { … } func (d *dynamicInformer) Lister() cache.GenericLister { … }
Codebase Browser
kubernetes