...
1
16
17
18
19 package v1beta1
20
21 import (
22 "context"
23 time "time"
24
25 admissionregistrationv1beta1 "k8s.io/api/admissionregistration/v1beta1"
26 v1 "k8s.io/apimachinery/pkg/apis/meta/v1"
27 runtime "k8s.io/apimachinery/pkg/runtime"
28 watch "k8s.io/apimachinery/pkg/watch"
29 internalinterfaces "k8s.io/client-go/informers/internalinterfaces"
30 kubernetes "k8s.io/client-go/kubernetes"
31 v1beta1 "k8s.io/client-go/listers/admissionregistration/v1beta1"
32 cache "k8s.io/client-go/tools/cache"
33 )
34
35
36
37 type MutatingWebhookConfigurationInformer interface {
38 Informer() cache.SharedIndexInformer
39 Lister() v1beta1.MutatingWebhookConfigurationLister
40 }
41
42 type mutatingWebhookConfigurationInformer struct {
43 factory internalinterfaces.SharedInformerFactory
44 tweakListOptions internalinterfaces.TweakListOptionsFunc
45 }
46
47
48
49
50 func NewMutatingWebhookConfigurationInformer(client kubernetes.Interface, resyncPeriod time.Duration, indexers cache.Indexers) cache.SharedIndexInformer {
51 return NewFilteredMutatingWebhookConfigurationInformer(client, resyncPeriod, indexers, nil)
52 }
53
54
55
56
57 func NewFilteredMutatingWebhookConfigurationInformer(client kubernetes.Interface, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
58 return cache.NewSharedIndexInformer(
59 &cache.ListWatch{
60 ListFunc: func(options v1.ListOptions) (runtime.Object, error) {
61 if tweakListOptions != nil {
62 tweakListOptions(&options)
63 }
64 return client.AdmissionregistrationV1beta1().MutatingWebhookConfigurations().List(context.TODO(), options)
65 },
66 WatchFunc: func(options v1.ListOptions) (watch.Interface, error) {
67 if tweakListOptions != nil {
68 tweakListOptions(&options)
69 }
70 return client.AdmissionregistrationV1beta1().MutatingWebhookConfigurations().Watch(context.TODO(), options)
71 },
72 },
73 &admissionregistrationv1beta1.MutatingWebhookConfiguration{},
74 resyncPeriod,
75 indexers,
76 )
77 }
78
79 func (f *mutatingWebhookConfigurationInformer) defaultInformer(client kubernetes.Interface, resyncPeriod time.Duration) cache.SharedIndexInformer {
80 return NewFilteredMutatingWebhookConfigurationInformer(client, resyncPeriod, cache.Indexers{cache.NamespaceIndex: cache.MetaNamespaceIndexFunc}, f.tweakListOptions)
81 }
82
83 func (f *mutatingWebhookConfigurationInformer) Informer() cache.SharedIndexInformer {
84 return f.factory.InformerFor(&admissionregistrationv1beta1.MutatingWebhookConfiguration{}, f.defaultInformer)
85 }
86
87 func (f *mutatingWebhookConfigurationInformer) Lister() v1beta1.MutatingWebhookConfigurationLister {
88 return v1beta1.NewMutatingWebhookConfigurationLister(f.Informer().GetIndexer())
89 }
90
View as plain text