/* MIT License */ // Code generated by informer-gen. DO NOT EDIT. package v1alpha1 import ( context "context" time "time" apismonok8sv1alpha1 "example.com/monok8s/pkg/apis/monok8s/v1alpha1" versioned "example.com/monok8s/pkg/generated/clientset/versioned" internalinterfaces "example.com/monok8s/pkg/generated/informers/externalversions/internalinterfaces" monok8sv1alpha1 "example.com/monok8s/pkg/generated/listers/monok8s/v1alpha1" v1 "k8s.io/apimachinery/pkg/apis/meta/v1" runtime "k8s.io/apimachinery/pkg/runtime" watch "k8s.io/apimachinery/pkg/watch" cache "k8s.io/client-go/tools/cache" ) // OSUpgradeProgressInformer provides access to a shared informer and lister for // OSUpgradeProgresses. type OSUpgradeProgressInformer interface { Informer() cache.SharedIndexInformer Lister() monok8sv1alpha1.OSUpgradeProgressLister } type oSUpgradeProgressInformer struct { factory internalinterfaces.SharedInformerFactory tweakListOptions internalinterfaces.TweakListOptionsFunc namespace string } // NewOSUpgradeProgressInformer constructs a new informer for OSUpgradeProgress type. // Always prefer using an informer factory to get a shared informer instead of getting an independent // one. This reduces memory footprint and number of connections to the server. func NewOSUpgradeProgressInformer(client versioned.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers) cache.SharedIndexInformer { return NewFilteredOSUpgradeProgressInformer(client, namespace, resyncPeriod, indexers, nil) } // NewFilteredOSUpgradeProgressInformer constructs a new informer for OSUpgradeProgress type. // Always prefer using an informer factory to get a shared informer instead of getting an independent // one. This reduces memory footprint and number of connections to the server. func NewFilteredOSUpgradeProgressInformer(client versioned.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer { return cache.NewSharedIndexInformer( cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{ ListFunc: func(options v1.ListOptions) (runtime.Object, error) { if tweakListOptions != nil { tweakListOptions(&options) } return client.Monok8sV1alpha1().OSUpgradeProgresses(namespace).List(context.Background(), options) }, WatchFunc: func(options v1.ListOptions) (watch.Interface, error) { if tweakListOptions != nil { tweakListOptions(&options) } return client.Monok8sV1alpha1().OSUpgradeProgresses(namespace).Watch(context.Background(), options) }, ListWithContextFunc: func(ctx context.Context, options v1.ListOptions) (runtime.Object, error) { if tweakListOptions != nil { tweakListOptions(&options) } return client.Monok8sV1alpha1().OSUpgradeProgresses(namespace).List(ctx, options) }, WatchFuncWithContext: func(ctx context.Context, options v1.ListOptions) (watch.Interface, error) { if tweakListOptions != nil { tweakListOptions(&options) } return client.Monok8sV1alpha1().OSUpgradeProgresses(namespace).Watch(ctx, options) }, }, client), &apismonok8sv1alpha1.OSUpgradeProgress{}, resyncPeriod, indexers, ) } func (f *oSUpgradeProgressInformer) defaultInformer(client versioned.Interface, resyncPeriod time.Duration) cache.SharedIndexInformer { return NewFilteredOSUpgradeProgressInformer(client, f.namespace, resyncPeriod, cache.Indexers{cache.NamespaceIndex: cache.MetaNamespaceIndexFunc}, f.tweakListOptions) } func (f *oSUpgradeProgressInformer) Informer() cache.SharedIndexInformer { return f.factory.InformerFor(&apismonok8sv1alpha1.OSUpgradeProgress{}, f.defaultInformer) } func (f *oSUpgradeProgressInformer) Lister() monok8sv1alpha1.OSUpgradeProgressLister { return monok8sv1alpha1.NewOSUpgradeProgressLister(f.Informer().GetIndexer()) }