upstream/kubernetes
1
0
Fork 0
mirror of https://github.com/kubernetes/kubernetes.git synced 2026-05-28 04:04:39 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions

Merge pull request #134714 from p0lyn0mial/upstream-watchlist-unsupported-wl-semantics-typed-inf

Browse source 
client-go/typed/informers: wrap the LW with WatchList semantics
This commit is contained in:
Kubernetes Prow Robot 2025-10-21 07:30:41 -07:00 committed by GitHub
commit 350481c474
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
162 changed files with 476 additions and 369 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/informers/externalversions/cr/v1/example.go
View file

@ -57,7 +57,7 @@ func NewExampleInformer(client versioned.Interface, namespace string, resyncPeri
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredExampleInformer(client versioned.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options metav1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -82,7 +82,7 @@ func NewFilteredExampleInformer(client versioned.Interface, namespace string, re
}
return client.CrV1().Examples(namespace).Watch(ctx, options)
},
},
}, client),
&apiscrv1.Example{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/apiextensions-apiserver/pkg/client/informers/externalversions/apiextensions/v1/customresourcedefinition.go
View file

@ -56,7 +56,7 @@ func NewCustomResourceDefinitionInformer(client clientset.Interface, resyncPerio
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredCustomResourceDefinitionInformer(client clientset.Interface, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options metav1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -81,7 +81,7 @@ func NewFilteredCustomResourceDefinitionInformer(client clientset.Interface, res
}
return client.ApiextensionsV1().CustomResourceDefinitions().Watch(ctx, options)
},
},
}, client),
&apisapiextensionsv1.CustomResourceDefinition{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/apiextensions-apiserver/pkg/client/informers/externalversions/apiextensions/v1beta1/customresourcedefinition.go
View file

@ -56,7 +56,7 @@ func NewCustomResourceDefinitionInformer(client clientset.Interface, resyncPerio
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredCustomResourceDefinitionInformer(client clientset.Interface, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options v1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -81,7 +81,7 @@ func NewFilteredCustomResourceDefinitionInformer(client clientset.Interface, res
}
return client.ApiextensionsV1beta1().CustomResourceDefinitions().Watch(ctx, options)
},
},
}, client),
&apisapiextensionsv1beta1.CustomResourceDefinition{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/admissionregistration/v1/mutatingwebhookconfiguration.go
View file

@ -56,7 +56,7 @@ func NewMutatingWebhookConfigurationInformer(client kubernetes.Interface, resync
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredMutatingWebhookConfigurationInformer(client kubernetes.Interface, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options metav1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -81,7 +81,7 @@ func NewFilteredMutatingWebhookConfigurationInformer(client kubernetes.Interface
}
return client.AdmissionregistrationV1().MutatingWebhookConfigurations().Watch(ctx, options)
},
},
}, client),
&apiadmissionregistrationv1.MutatingWebhookConfiguration{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/admissionregistration/v1/validatingadmissionpolicy.go
View file

@ -56,7 +56,7 @@ func NewValidatingAdmissionPolicyInformer(client kubernetes.Interface, resyncPer
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredValidatingAdmissionPolicyInformer(client kubernetes.Interface, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options metav1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -81,7 +81,7 @@ func NewFilteredValidatingAdmissionPolicyInformer(client kubernetes.Interface, r
}
return client.AdmissionregistrationV1().ValidatingAdmissionPolicies().Watch(ctx, options)
},
},
}, client),
&apiadmissionregistrationv1.ValidatingAdmissionPolicy{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/admissionregistration/v1/validatingadmissionpolicybinding.go
View file

@ -56,7 +56,7 @@ func NewValidatingAdmissionPolicyBindingInformer(client kubernetes.Interface, re
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredValidatingAdmissionPolicyBindingInformer(client kubernetes.Interface, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options metav1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -81,7 +81,7 @@ func NewFilteredValidatingAdmissionPolicyBindingInformer(client kubernetes.Inter
}
return client.AdmissionregistrationV1().ValidatingAdmissionPolicyBindings().Watch(ctx, options)
},
},
}, client),
&apiadmissionregistrationv1.ValidatingAdmissionPolicyBinding{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/admissionregistration/v1/validatingwebhookconfiguration.go
View file

@ -56,7 +56,7 @@ func NewValidatingWebhookConfigurationInformer(client kubernetes.Interface, resy
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredValidatingWebhookConfigurationInformer(client kubernetes.Interface, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options metav1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -81,7 +81,7 @@ func NewFilteredValidatingWebhookConfigurationInformer(client kubernetes.Interfa
}
return client.AdmissionregistrationV1().ValidatingWebhookConfigurations().Watch(ctx, options)
},
},
}, client),
&apiadmissionregistrationv1.ValidatingWebhookConfiguration{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/admissionregistration/v1alpha1/mutatingadmissionpolicy.go
View file

@ -56,7 +56,7 @@ func NewMutatingAdmissionPolicyInformer(client kubernetes.Interface, resyncPerio
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredMutatingAdmissionPolicyInformer(client kubernetes.Interface, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options v1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -81,7 +81,7 @@ func NewFilteredMutatingAdmissionPolicyInformer(client kubernetes.Interface, res
}
return client.AdmissionregistrationV1alpha1().MutatingAdmissionPolicies().Watch(ctx, options)
},
},
}, client),
&apiadmissionregistrationv1alpha1.MutatingAdmissionPolicy{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/admissionregistration/v1alpha1/mutatingadmissionpolicybinding.go
View file

@ -56,7 +56,7 @@ func NewMutatingAdmissionPolicyBindingInformer(client kubernetes.Interface, resy
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredMutatingAdmissionPolicyBindingInformer(client kubernetes.Interface, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options v1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -81,7 +81,7 @@ func NewFilteredMutatingAdmissionPolicyBindingInformer(client kubernetes.Interfa
}
return client.AdmissionregistrationV1alpha1().MutatingAdmissionPolicyBindings().Watch(ctx, options)
},
},
}, client),
&apiadmissionregistrationv1alpha1.MutatingAdmissionPolicyBinding{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/admissionregistration/v1alpha1/validatingadmissionpolicy.go
View file

@ -56,7 +56,7 @@ func NewValidatingAdmissionPolicyInformer(client kubernetes.Interface, resyncPer
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredValidatingAdmissionPolicyInformer(client kubernetes.Interface, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options v1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -81,7 +81,7 @@ func NewFilteredValidatingAdmissionPolicyInformer(client kubernetes.Interface, r
}
return client.AdmissionregistrationV1alpha1().ValidatingAdmissionPolicies().Watch(ctx, options)
},
},
}, client),
&apiadmissionregistrationv1alpha1.ValidatingAdmissionPolicy{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/admissionregistration/v1alpha1/validatingadmissionpolicybinding.go
View file

@ -56,7 +56,7 @@ func NewValidatingAdmissionPolicyBindingInformer(client kubernetes.Interface, re
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredValidatingAdmissionPolicyBindingInformer(client kubernetes.Interface, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options v1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -81,7 +81,7 @@ func NewFilteredValidatingAdmissionPolicyBindingInformer(client kubernetes.Inter
}
return client.AdmissionregistrationV1alpha1().ValidatingAdmissionPolicyBindings().Watch(ctx, options)
},
},
}, client),
&apiadmissionregistrationv1alpha1.ValidatingAdmissionPolicyBinding{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/admissionregistration/v1beta1/mutatingadmissionpolicy.go
View file

@ -56,7 +56,7 @@ func NewMutatingAdmissionPolicyInformer(client kubernetes.Interface, resyncPerio
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredMutatingAdmissionPolicyInformer(client kubernetes.Interface, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options v1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -81,7 +81,7 @@ func NewFilteredMutatingAdmissionPolicyInformer(client kubernetes.Interface, res
}
return client.AdmissionregistrationV1beta1().MutatingAdmissionPolicies().Watch(ctx, options)
},
},
}, client),
&apiadmissionregistrationv1beta1.MutatingAdmissionPolicy{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/admissionregistration/v1beta1/mutatingadmissionpolicybinding.go
View file

@ -56,7 +56,7 @@ func NewMutatingAdmissionPolicyBindingInformer(client kubernetes.Interface, resy
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredMutatingAdmissionPolicyBindingInformer(client kubernetes.Interface, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options v1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -81,7 +81,7 @@ func NewFilteredMutatingAdmissionPolicyBindingInformer(client kubernetes.Interfa
}
return client.AdmissionregistrationV1beta1().MutatingAdmissionPolicyBindings().Watch(ctx, options)
},
},
}, client),
&apiadmissionregistrationv1beta1.MutatingAdmissionPolicyBinding{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/admissionregistration/v1beta1/mutatingwebhookconfiguration.go
View file

@ -56,7 +56,7 @@ func NewMutatingWebhookConfigurationInformer(client kubernetes.Interface, resync
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredMutatingWebhookConfigurationInformer(client kubernetes.Interface, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options v1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -81,7 +81,7 @@ func NewFilteredMutatingWebhookConfigurationInformer(client kubernetes.Interface
}
return client.AdmissionregistrationV1beta1().MutatingWebhookConfigurations().Watch(ctx, options)
},
},
}, client),
&apiadmissionregistrationv1beta1.MutatingWebhookConfiguration{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/admissionregistration/v1beta1/validatingadmissionpolicy.go
View file

@ -56,7 +56,7 @@ func NewValidatingAdmissionPolicyInformer(client kubernetes.Interface, resyncPer
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredValidatingAdmissionPolicyInformer(client kubernetes.Interface, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options v1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -81,7 +81,7 @@ func NewFilteredValidatingAdmissionPolicyInformer(client kubernetes.Interface, r
}
return client.AdmissionregistrationV1beta1().ValidatingAdmissionPolicies().Watch(ctx, options)
},
},
}, client),
&apiadmissionregistrationv1beta1.ValidatingAdmissionPolicy{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/admissionregistration/v1beta1/validatingadmissionpolicybinding.go
View file

@ -56,7 +56,7 @@ func NewValidatingAdmissionPolicyBindingInformer(client kubernetes.Interface, re
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredValidatingAdmissionPolicyBindingInformer(client kubernetes.Interface, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options v1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -81,7 +81,7 @@ func NewFilteredValidatingAdmissionPolicyBindingInformer(client kubernetes.Inter
}
return client.AdmissionregistrationV1beta1().ValidatingAdmissionPolicyBindings().Watch(ctx, options)
},
},
}, client),
&apiadmissionregistrationv1beta1.ValidatingAdmissionPolicyBinding{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/admissionregistration/v1beta1/validatingwebhookconfiguration.go
View file

@ -56,7 +56,7 @@ func NewValidatingWebhookConfigurationInformer(client kubernetes.Interface, resy
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredValidatingWebhookConfigurationInformer(client kubernetes.Interface, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options v1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -81,7 +81,7 @@ func NewFilteredValidatingWebhookConfigurationInformer(client kubernetes.Interfa
}
return client.AdmissionregistrationV1beta1().ValidatingWebhookConfigurations().Watch(ctx, options)
},
},
}, client),
&apiadmissionregistrationv1beta1.ValidatingWebhookConfiguration{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/apiserverinternal/v1alpha1/storageversion.go
View file

@ -56,7 +56,7 @@ func NewStorageVersionInformer(client kubernetes.Interface, resyncPeriod time.Du
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredStorageVersionInformer(client kubernetes.Interface, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options v1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -81,7 +81,7 @@ func NewFilteredStorageVersionInformer(client kubernetes.Interface, resyncPeriod
}
return client.InternalV1alpha1().StorageVersions().Watch(ctx, options)
},
},
}, client),
&apiapiserverinternalv1alpha1.StorageVersion{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/apps/v1/controllerrevision.go
View file

@ -57,7 +57,7 @@ func NewControllerRevisionInformer(client kubernetes.Interface, namespace string
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredControllerRevisionInformer(client kubernetes.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options metav1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -82,7 +82,7 @@ func NewFilteredControllerRevisionInformer(client kubernetes.Interface, namespac
}
return client.AppsV1().ControllerRevisions(namespace).Watch(ctx, options)
},
},
}, client),
&apiappsv1.ControllerRevision{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/apps/v1/daemonset.go
View file

@ -57,7 +57,7 @@ func NewDaemonSetInformer(client kubernetes.Interface, namespace string, resyncP
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredDaemonSetInformer(client kubernetes.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options metav1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -82,7 +82,7 @@ func NewFilteredDaemonSetInformer(client kubernetes.Interface, namespace string,
}
return client.AppsV1().DaemonSets(namespace).Watch(ctx, options)
},
},
}, client),
&apiappsv1.DaemonSet{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/apps/v1/deployment.go
View file

@ -57,7 +57,7 @@ func NewDeploymentInformer(client kubernetes.Interface, namespace string, resync
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredDeploymentInformer(client kubernetes.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options metav1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -82,7 +82,7 @@ func NewFilteredDeploymentInformer(client kubernetes.Interface, namespace string
}
return client.AppsV1().Deployments(namespace).Watch(ctx, options)
},
},
}, client),
&apiappsv1.Deployment{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/apps/v1/replicaset.go
View file

@ -57,7 +57,7 @@ func NewReplicaSetInformer(client kubernetes.Interface, namespace string, resync
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredReplicaSetInformer(client kubernetes.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options metav1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -82,7 +82,7 @@ func NewFilteredReplicaSetInformer(client kubernetes.Interface, namespace string
}
return client.AppsV1().ReplicaSets(namespace).Watch(ctx, options)
},
},
}, client),
&apiappsv1.ReplicaSet{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/apps/v1/statefulset.go
View file

@ -57,7 +57,7 @@ func NewStatefulSetInformer(client kubernetes.Interface, namespace string, resyn
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredStatefulSetInformer(client kubernetes.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options metav1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -82,7 +82,7 @@ func NewFilteredStatefulSetInformer(client kubernetes.Interface, namespace strin
}
return client.AppsV1().StatefulSets(namespace).Watch(ctx, options)
},
},
}, client),
&apiappsv1.StatefulSet{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/apps/v1beta1/controllerrevision.go
View file

@ -57,7 +57,7 @@ func NewControllerRevisionInformer(client kubernetes.Interface, namespace string
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredControllerRevisionInformer(client kubernetes.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options v1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -82,7 +82,7 @@ func NewFilteredControllerRevisionInformer(client kubernetes.Interface, namespac
}
return client.AppsV1beta1().ControllerRevisions(namespace).Watch(ctx, options)
},
},
}, client),
&apiappsv1beta1.ControllerRevision{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/apps/v1beta1/deployment.go
View file

@ -57,7 +57,7 @@ func NewDeploymentInformer(client kubernetes.Interface, namespace string, resync
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredDeploymentInformer(client kubernetes.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options v1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -82,7 +82,7 @@ func NewFilteredDeploymentInformer(client kubernetes.Interface, namespace string
}
return client.AppsV1beta1().Deployments(namespace).Watch(ctx, options)
},
},
}, client),
&apiappsv1beta1.Deployment{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/apps/v1beta1/statefulset.go
View file

@ -57,7 +57,7 @@ func NewStatefulSetInformer(client kubernetes.Interface, namespace string, resyn
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredStatefulSetInformer(client kubernetes.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options v1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -82,7 +82,7 @@ func NewFilteredStatefulSetInformer(client kubernetes.Interface, namespace strin
}
return client.AppsV1beta1().StatefulSets(namespace).Watch(ctx, options)
},
},
}, client),
&apiappsv1beta1.StatefulSet{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/apps/v1beta2/controllerrevision.go
View file

@ -57,7 +57,7 @@ func NewControllerRevisionInformer(client kubernetes.Interface, namespace string
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredControllerRevisionInformer(client kubernetes.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options v1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -82,7 +82,7 @@ func NewFilteredControllerRevisionInformer(client kubernetes.Interface, namespac
}
return client.AppsV1beta2().ControllerRevisions(namespace).Watch(ctx, options)
},
},
}, client),
&apiappsv1beta2.ControllerRevision{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/apps/v1beta2/daemonset.go
View file

@ -57,7 +57,7 @@ func NewDaemonSetInformer(client kubernetes.Interface, namespace string, resyncP
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredDaemonSetInformer(client kubernetes.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options v1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -82,7 +82,7 @@ func NewFilteredDaemonSetInformer(client kubernetes.Interface, namespace string,
}
return client.AppsV1beta2().DaemonSets(namespace).Watch(ctx, options)
},
},
}, client),
&apiappsv1beta2.DaemonSet{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/apps/v1beta2/deployment.go
View file

@ -57,7 +57,7 @@ func NewDeploymentInformer(client kubernetes.Interface, namespace string, resync
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredDeploymentInformer(client kubernetes.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options v1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -82,7 +82,7 @@ func NewFilteredDeploymentInformer(client kubernetes.Interface, namespace string
}
return client.AppsV1beta2().Deployments(namespace).Watch(ctx, options)
},
},
}, client),
&apiappsv1beta2.Deployment{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/apps/v1beta2/replicaset.go
View file

@ -57,7 +57,7 @@ func NewReplicaSetInformer(client kubernetes.Interface, namespace string, resync
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredReplicaSetInformer(client kubernetes.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options v1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -82,7 +82,7 @@ func NewFilteredReplicaSetInformer(client kubernetes.Interface, namespace string
}
return client.AppsV1beta2().ReplicaSets(namespace).Watch(ctx, options)
},
},
}, client),
&apiappsv1beta2.ReplicaSet{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/apps/v1beta2/statefulset.go
View file

@ -57,7 +57,7 @@ func NewStatefulSetInformer(client kubernetes.Interface, namespace string, resyn
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredStatefulSetInformer(client kubernetes.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options v1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -82,7 +82,7 @@ func NewFilteredStatefulSetInformer(client kubernetes.Interface, namespace strin
}
return client.AppsV1beta2().StatefulSets(namespace).Watch(ctx, options)
},
},
}, client),
&apiappsv1beta2.StatefulSet{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/autoscaling/v1/horizontalpodautoscaler.go
View file

@ -57,7 +57,7 @@ func NewHorizontalPodAutoscalerInformer(client kubernetes.Interface, namespace s
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredHorizontalPodAutoscalerInformer(client kubernetes.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options metav1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -82,7 +82,7 @@ func NewFilteredHorizontalPodAutoscalerInformer(client kubernetes.Interface, nam
}
return client.AutoscalingV1().HorizontalPodAutoscalers(namespace).Watch(ctx, options)
},
},
}, client),
&apiautoscalingv1.HorizontalPodAutoscaler{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/autoscaling/v2/horizontalpodautoscaler.go
View file

@ -57,7 +57,7 @@ func NewHorizontalPodAutoscalerInformer(client kubernetes.Interface, namespace s
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredHorizontalPodAutoscalerInformer(client kubernetes.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options v1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -82,7 +82,7 @@ func NewFilteredHorizontalPodAutoscalerInformer(client kubernetes.Interface, nam
}
return client.AutoscalingV2().HorizontalPodAutoscalers(namespace).Watch(ctx, options)
},
},
}, client),
&apiautoscalingv2.HorizontalPodAutoscaler{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/autoscaling/v2beta1/horizontalpodautoscaler.go
View file

@ -57,7 +57,7 @@ func NewHorizontalPodAutoscalerInformer(client kubernetes.Interface, namespace s
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredHorizontalPodAutoscalerInformer(client kubernetes.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options v1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -82,7 +82,7 @@ func NewFilteredHorizontalPodAutoscalerInformer(client kubernetes.Interface, nam
}
return client.AutoscalingV2beta1().HorizontalPodAutoscalers(namespace).Watch(ctx, options)
},
},
}, client),
&apiautoscalingv2beta1.HorizontalPodAutoscaler{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/autoscaling/v2beta2/horizontalpodautoscaler.go
View file

@ -57,7 +57,7 @@ func NewHorizontalPodAutoscalerInformer(client kubernetes.Interface, namespace s
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredHorizontalPodAutoscalerInformer(client kubernetes.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options v1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -82,7 +82,7 @@ func NewFilteredHorizontalPodAutoscalerInformer(client kubernetes.Interface, nam
}
return client.AutoscalingV2beta2().HorizontalPodAutoscalers(namespace).Watch(ctx, options)
},
},
}, client),
&apiautoscalingv2beta2.HorizontalPodAutoscaler{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/batch/v1/cronjob.go
View file

@ -57,7 +57,7 @@ func NewCronJobInformer(client kubernetes.Interface, namespace string, resyncPer
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredCronJobInformer(client kubernetes.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options metav1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -82,7 +82,7 @@ func NewFilteredCronJobInformer(client kubernetes.Interface, namespace string, r
}
return client.BatchV1().CronJobs(namespace).Watch(ctx, options)
},
},
}, client),
&apibatchv1.CronJob{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/batch/v1/job.go
View file

@ -57,7 +57,7 @@ func NewJobInformer(client kubernetes.Interface, namespace string, resyncPeriod
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredJobInformer(client kubernetes.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options metav1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -82,7 +82,7 @@ func NewFilteredJobInformer(client kubernetes.Interface, namespace string, resyn
}
return client.BatchV1().Jobs(namespace).Watch(ctx, options)
},
},
}, client),
&apibatchv1.Job{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/batch/v1beta1/cronjob.go
View file

@ -57,7 +57,7 @@ func NewCronJobInformer(client kubernetes.Interface, namespace string, resyncPer
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredCronJobInformer(client kubernetes.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options v1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -82,7 +82,7 @@ func NewFilteredCronJobInformer(client kubernetes.Interface, namespace string, r
}
return client.BatchV1beta1().CronJobs(namespace).Watch(ctx, options)
},
},
}, client),
&apibatchv1beta1.CronJob{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/certificates/v1/certificatesigningrequest.go
View file

@ -56,7 +56,7 @@ func NewCertificateSigningRequestInformer(client kubernetes.Interface, resyncPer
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredCertificateSigningRequestInformer(client kubernetes.Interface, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options metav1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -81,7 +81,7 @@ func NewFilteredCertificateSigningRequestInformer(client kubernetes.Interface, r
}
return client.CertificatesV1().CertificateSigningRequests().Watch(ctx, options)
},
},
}, client),
&apicertificatesv1.CertificateSigningRequest{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/certificates/v1alpha1/clustertrustbundle.go
View file

@ -56,7 +56,7 @@ func NewClusterTrustBundleInformer(client kubernetes.Interface, resyncPeriod tim
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredClusterTrustBundleInformer(client kubernetes.Interface, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options v1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -81,7 +81,7 @@ func NewFilteredClusterTrustBundleInformer(client kubernetes.Interface, resyncPe
}
return client.CertificatesV1alpha1().ClusterTrustBundles().Watch(ctx, options)
},
},
}, client),
&apicertificatesv1alpha1.ClusterTrustBundle{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/certificates/v1alpha1/podcertificaterequest.go
View file

@ -57,7 +57,7 @@ func NewPodCertificateRequestInformer(client kubernetes.Interface, namespace str
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredPodCertificateRequestInformer(client kubernetes.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options v1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -82,7 +82,7 @@ func NewFilteredPodCertificateRequestInformer(client kubernetes.Interface, names
}
return client.CertificatesV1alpha1().PodCertificateRequests(namespace).Watch(ctx, options)
},
},
}, client),
&apicertificatesv1alpha1.PodCertificateRequest{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/certificates/v1beta1/certificatesigningrequest.go
View file

@ -56,7 +56,7 @@ func NewCertificateSigningRequestInformer(client kubernetes.Interface, resyncPer
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredCertificateSigningRequestInformer(client kubernetes.Interface, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options v1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -81,7 +81,7 @@ func NewFilteredCertificateSigningRequestInformer(client kubernetes.Interface, r
}
return client.CertificatesV1beta1().CertificateSigningRequests().Watch(ctx, options)
},
},
}, client),
&apicertificatesv1beta1.CertificateSigningRequest{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/certificates/v1beta1/clustertrustbundle.go
View file

@ -56,7 +56,7 @@ func NewClusterTrustBundleInformer(client kubernetes.Interface, resyncPeriod tim
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredClusterTrustBundleInformer(client kubernetes.Interface, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options v1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -81,7 +81,7 @@ func NewFilteredClusterTrustBundleInformer(client kubernetes.Interface, resyncPe
}
return client.CertificatesV1beta1().ClusterTrustBundles().Watch(ctx, options)
},
},
}, client),
&apicertificatesv1beta1.ClusterTrustBundle{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/coordination/v1/lease.go
View file

@ -57,7 +57,7 @@ func NewLeaseInformer(client kubernetes.Interface, namespace string, resyncPerio
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredLeaseInformer(client kubernetes.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options metav1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -82,7 +82,7 @@ func NewFilteredLeaseInformer(client kubernetes.Interface, namespace string, res
}
return client.CoordinationV1().Leases(namespace).Watch(ctx, options)
},
},
}, client),
&apicoordinationv1.Lease{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/coordination/v1alpha2/leasecandidate.go
View file

@ -57,7 +57,7 @@ func NewLeaseCandidateInformer(client kubernetes.Interface, namespace string, re
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredLeaseCandidateInformer(client kubernetes.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options v1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -82,7 +82,7 @@ func NewFilteredLeaseCandidateInformer(client kubernetes.Interface, namespace st
}
return client.CoordinationV1alpha2().LeaseCandidates(namespace).Watch(ctx, options)
},
},
}, client),
&apicoordinationv1alpha2.LeaseCandidate{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/coordination/v1beta1/lease.go
View file

@ -57,7 +57,7 @@ func NewLeaseInformer(client kubernetes.Interface, namespace string, resyncPerio
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredLeaseInformer(client kubernetes.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options v1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -82,7 +82,7 @@ func NewFilteredLeaseInformer(client kubernetes.Interface, namespace string, res
}
return client.CoordinationV1beta1().Leases(namespace).Watch(ctx, options)
},
},
}, client),
&apicoordinationv1beta1.Lease{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/coordination/v1beta1/leasecandidate.go
View file

@ -57,7 +57,7 @@ func NewLeaseCandidateInformer(client kubernetes.Interface, namespace string, re
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredLeaseCandidateInformer(client kubernetes.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options v1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -82,7 +82,7 @@ func NewFilteredLeaseCandidateInformer(client kubernetes.Interface, namespace st
}
return client.CoordinationV1beta1().LeaseCandidates(namespace).Watch(ctx, options)
},
},
}, client),
&apicoordinationv1beta1.LeaseCandidate{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/core/v1/componentstatus.go
View file

@ -56,7 +56,7 @@ func NewComponentStatusInformer(client kubernetes.Interface, resyncPeriod time.D
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredComponentStatusInformer(client kubernetes.Interface, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options metav1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -81,7 +81,7 @@ func NewFilteredComponentStatusInformer(client kubernetes.Interface, resyncPerio
}
return client.CoreV1().ComponentStatuses().Watch(ctx, options)
},
},
}, client),
&apicorev1.ComponentStatus{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/core/v1/configmap.go
View file

@ -57,7 +57,7 @@ func NewConfigMapInformer(client kubernetes.Interface, namespace string, resyncP
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredConfigMapInformer(client kubernetes.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options metav1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -82,7 +82,7 @@ func NewFilteredConfigMapInformer(client kubernetes.Interface, namespace string,
}
return client.CoreV1().ConfigMaps(namespace).Watch(ctx, options)
},
},
}, client),
&apicorev1.ConfigMap{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/core/v1/endpoints.go
View file

@ -57,7 +57,7 @@ func NewEndpointsInformer(client kubernetes.Interface, namespace string, resyncP
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredEndpointsInformer(client kubernetes.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options metav1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -82,7 +82,7 @@ func NewFilteredEndpointsInformer(client kubernetes.Interface, namespace string,
}
return client.CoreV1().Endpoints(namespace).Watch(ctx, options)
},
},
}, client),
&apicorev1.Endpoints{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/core/v1/event.go
View file

@ -57,7 +57,7 @@ func NewEventInformer(client kubernetes.Interface, namespace string, resyncPerio
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredEventInformer(client kubernetes.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options metav1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -82,7 +82,7 @@ func NewFilteredEventInformer(client kubernetes.Interface, namespace string, res
}
return client.CoreV1().Events(namespace).Watch(ctx, options)
},
},
}, client),
&apicorev1.Event{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/core/v1/limitrange.go
View file

@ -57,7 +57,7 @@ func NewLimitRangeInformer(client kubernetes.Interface, namespace string, resync
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredLimitRangeInformer(client kubernetes.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options metav1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -82,7 +82,7 @@ func NewFilteredLimitRangeInformer(client kubernetes.Interface, namespace string
}
return client.CoreV1().LimitRanges(namespace).Watch(ctx, options)
},
},
}, client),
&apicorev1.LimitRange{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/core/v1/namespace.go
View file

@ -56,7 +56,7 @@ func NewNamespaceInformer(client kubernetes.Interface, resyncPeriod time.Duratio
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredNamespaceInformer(client kubernetes.Interface, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options metav1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -81,7 +81,7 @@ func NewFilteredNamespaceInformer(client kubernetes.Interface, resyncPeriod time
}
return client.CoreV1().Namespaces().Watch(ctx, options)
},
},
}, client),
&apicorev1.Namespace{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/core/v1/node.go
View file

@ -56,7 +56,7 @@ func NewNodeInformer(client kubernetes.Interface, resyncPeriod time.Duration, in
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredNodeInformer(client kubernetes.Interface, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options metav1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -81,7 +81,7 @@ func NewFilteredNodeInformer(client kubernetes.Interface, resyncPeriod time.Dura
}
return client.CoreV1().Nodes().Watch(ctx, options)
},
},
}, client),
&apicorev1.Node{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/core/v1/persistentvolume.go
View file

@ -56,7 +56,7 @@ func NewPersistentVolumeInformer(client kubernetes.Interface, resyncPeriod time.
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredPersistentVolumeInformer(client kubernetes.Interface, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options metav1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -81,7 +81,7 @@ func NewFilteredPersistentVolumeInformer(client kubernetes.Interface, resyncPeri
}
return client.CoreV1().PersistentVolumes().Watch(ctx, options)
},
},
}, client),
&apicorev1.PersistentVolume{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/core/v1/persistentvolumeclaim.go
View file

@ -57,7 +57,7 @@ func NewPersistentVolumeClaimInformer(client kubernetes.Interface, namespace str
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredPersistentVolumeClaimInformer(client kubernetes.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options metav1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -82,7 +82,7 @@ func NewFilteredPersistentVolumeClaimInformer(client kubernetes.Interface, names
}
return client.CoreV1().PersistentVolumeClaims(namespace).Watch(ctx, options)
},
},
}, client),
&apicorev1.PersistentVolumeClaim{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/core/v1/pod.go
View file

@ -57,7 +57,7 @@ func NewPodInformer(client kubernetes.Interface, namespace string, resyncPeriod
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredPodInformer(client kubernetes.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options metav1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -82,7 +82,7 @@ func NewFilteredPodInformer(client kubernetes.Interface, namespace string, resyn
}
return client.CoreV1().Pods(namespace).Watch(ctx, options)
},
},
}, client),
&apicorev1.Pod{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/core/v1/podtemplate.go
View file

@ -57,7 +57,7 @@ func NewPodTemplateInformer(client kubernetes.Interface, namespace string, resyn
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredPodTemplateInformer(client kubernetes.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options metav1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -82,7 +82,7 @@ func NewFilteredPodTemplateInformer(client kubernetes.Interface, namespace strin
}
return client.CoreV1().PodTemplates(namespace).Watch(ctx, options)
},
},
}, client),
&apicorev1.PodTemplate{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/core/v1/replicationcontroller.go
View file

@ -57,7 +57,7 @@ func NewReplicationControllerInformer(client kubernetes.Interface, namespace str
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredReplicationControllerInformer(client kubernetes.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options metav1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -82,7 +82,7 @@ func NewFilteredReplicationControllerInformer(client kubernetes.Interface, names
}
return client.CoreV1().ReplicationControllers(namespace).Watch(ctx, options)
},
},
}, client),
&apicorev1.ReplicationController{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/core/v1/resourcequota.go
View file

@ -57,7 +57,7 @@ func NewResourceQuotaInformer(client kubernetes.Interface, namespace string, res
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredResourceQuotaInformer(client kubernetes.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options metav1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -82,7 +82,7 @@ func NewFilteredResourceQuotaInformer(client kubernetes.Interface, namespace str
}
return client.CoreV1().ResourceQuotas(namespace).Watch(ctx, options)
},
},
}, client),
&apicorev1.ResourceQuota{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/core/v1/secret.go
View file

@ -57,7 +57,7 @@ func NewSecretInformer(client kubernetes.Interface, namespace string, resyncPeri
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredSecretInformer(client kubernetes.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options metav1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -82,7 +82,7 @@ func NewFilteredSecretInformer(client kubernetes.Interface, namespace string, re
}
return client.CoreV1().Secrets(namespace).Watch(ctx, options)
},
},
}, client),
&apicorev1.Secret{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/core/v1/service.go
View file

@ -57,7 +57,7 @@ func NewServiceInformer(client kubernetes.Interface, namespace string, resyncPer
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredServiceInformer(client kubernetes.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options metav1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -82,7 +82,7 @@ func NewFilteredServiceInformer(client kubernetes.Interface, namespace string, r
}
return client.CoreV1().Services(namespace).Watch(ctx, options)
},
},
}, client),
&apicorev1.Service{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/core/v1/serviceaccount.go
View file

@ -57,7 +57,7 @@ func NewServiceAccountInformer(client kubernetes.Interface, namespace string, re
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredServiceAccountInformer(client kubernetes.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options metav1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -82,7 +82,7 @@ func NewFilteredServiceAccountInformer(client kubernetes.Interface, namespace st
}
return client.CoreV1().ServiceAccounts(namespace).Watch(ctx, options)
},
},
}, client),
&apicorev1.ServiceAccount{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/discovery/v1/endpointslice.go
View file

@ -57,7 +57,7 @@ func NewEndpointSliceInformer(client kubernetes.Interface, namespace string, res
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredEndpointSliceInformer(client kubernetes.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options metav1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -82,7 +82,7 @@ func NewFilteredEndpointSliceInformer(client kubernetes.Interface, namespace str
}
return client.DiscoveryV1().EndpointSlices(namespace).Watch(ctx, options)
},
},
}, client),
&apidiscoveryv1.EndpointSlice{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/discovery/v1beta1/endpointslice.go
View file

@ -57,7 +57,7 @@ func NewEndpointSliceInformer(client kubernetes.Interface, namespace string, res
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredEndpointSliceInformer(client kubernetes.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options v1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -82,7 +82,7 @@ func NewFilteredEndpointSliceInformer(client kubernetes.Interface, namespace str
}
return client.DiscoveryV1beta1().EndpointSlices(namespace).Watch(ctx, options)
},
},
}, client),
&apidiscoveryv1beta1.EndpointSlice{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/events/v1/event.go
View file

@ -57,7 +57,7 @@ func NewEventInformer(client kubernetes.Interface, namespace string, resyncPerio
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredEventInformer(client kubernetes.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options metav1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -82,7 +82,7 @@ func NewFilteredEventInformer(client kubernetes.Interface, namespace string, res
}
return client.EventsV1().Events(namespace).Watch(ctx, options)
},
},
}, client),
&apieventsv1.Event{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/events/v1beta1/event.go
View file

@ -57,7 +57,7 @@ func NewEventInformer(client kubernetes.Interface, namespace string, resyncPerio
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredEventInformer(client kubernetes.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options v1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -82,7 +82,7 @@ func NewFilteredEventInformer(client kubernetes.Interface, namespace string, res
}
return client.EventsV1beta1().Events(namespace).Watch(ctx, options)
},
},
}, client),
&apieventsv1beta1.Event{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/extensions/v1beta1/daemonset.go
View file

@ -57,7 +57,7 @@ func NewDaemonSetInformer(client kubernetes.Interface, namespace string, resyncP
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredDaemonSetInformer(client kubernetes.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options v1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -82,7 +82,7 @@ func NewFilteredDaemonSetInformer(client kubernetes.Interface, namespace string,
}
return client.ExtensionsV1beta1().DaemonSets(namespace).Watch(ctx, options)
},
},
}, client),
&apiextensionsv1beta1.DaemonSet{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/extensions/v1beta1/deployment.go
View file

@ -57,7 +57,7 @@ func NewDeploymentInformer(client kubernetes.Interface, namespace string, resync
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredDeploymentInformer(client kubernetes.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options v1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -82,7 +82,7 @@ func NewFilteredDeploymentInformer(client kubernetes.Interface, namespace string
}
return client.ExtensionsV1beta1().Deployments(namespace).Watch(ctx, options)
},
},
}, client),
&apiextensionsv1beta1.Deployment{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/extensions/v1beta1/ingress.go
View file

@ -57,7 +57,7 @@ func NewIngressInformer(client kubernetes.Interface, namespace string, resyncPer
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredIngressInformer(client kubernetes.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options v1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -82,7 +82,7 @@ func NewFilteredIngressInformer(client kubernetes.Interface, namespace string, r
}
return client.ExtensionsV1beta1().Ingresses(namespace).Watch(ctx, options)
},
},
}, client),
&apiextensionsv1beta1.Ingress{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/extensions/v1beta1/networkpolicy.go
View file

@ -57,7 +57,7 @@ func NewNetworkPolicyInformer(client kubernetes.Interface, namespace string, res
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredNetworkPolicyInformer(client kubernetes.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options v1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -82,7 +82,7 @@ func NewFilteredNetworkPolicyInformer(client kubernetes.Interface, namespace str
}
return client.ExtensionsV1beta1().NetworkPolicies(namespace).Watch(ctx, options)
},
},
}, client),
&apiextensionsv1beta1.NetworkPolicy{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/extensions/v1beta1/replicaset.go
View file

@ -57,7 +57,7 @@ func NewReplicaSetInformer(client kubernetes.Interface, namespace string, resync
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredReplicaSetInformer(client kubernetes.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options v1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -82,7 +82,7 @@ func NewFilteredReplicaSetInformer(client kubernetes.Interface, namespace string
}
return client.ExtensionsV1beta1().ReplicaSets(namespace).Watch(ctx, options)
},
},
}, client),
&apiextensionsv1beta1.ReplicaSet{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/flowcontrol/v1/flowschema.go
View file

@ -56,7 +56,7 @@ func NewFlowSchemaInformer(client kubernetes.Interface, resyncPeriod time.Durati
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredFlowSchemaInformer(client kubernetes.Interface, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options metav1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -81,7 +81,7 @@ func NewFilteredFlowSchemaInformer(client kubernetes.Interface, resyncPeriod tim
}
return client.FlowcontrolV1().FlowSchemas().Watch(ctx, options)
},
},
}, client),
&apiflowcontrolv1.FlowSchema{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/flowcontrol/v1/prioritylevelconfiguration.go
View file

@ -56,7 +56,7 @@ func NewPriorityLevelConfigurationInformer(client kubernetes.Interface, resyncPe
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredPriorityLevelConfigurationInformer(client kubernetes.Interface, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options metav1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -81,7 +81,7 @@ func NewFilteredPriorityLevelConfigurationInformer(client kubernetes.Interface,
}
return client.FlowcontrolV1().PriorityLevelConfigurations().Watch(ctx, options)
},
},
}, client),
&apiflowcontrolv1.PriorityLevelConfiguration{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/flowcontrol/v1beta1/flowschema.go
View file

@ -56,7 +56,7 @@ func NewFlowSchemaInformer(client kubernetes.Interface, resyncPeriod time.Durati
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredFlowSchemaInformer(client kubernetes.Interface, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options v1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -81,7 +81,7 @@ func NewFilteredFlowSchemaInformer(client kubernetes.Interface, resyncPeriod tim
}
return client.FlowcontrolV1beta1().FlowSchemas().Watch(ctx, options)
},
},
}, client),
&apiflowcontrolv1beta1.FlowSchema{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/flowcontrol/v1beta1/prioritylevelconfiguration.go
View file

@ -56,7 +56,7 @@ func NewPriorityLevelConfigurationInformer(client kubernetes.Interface, resyncPe
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredPriorityLevelConfigurationInformer(client kubernetes.Interface, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options v1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -81,7 +81,7 @@ func NewFilteredPriorityLevelConfigurationInformer(client kubernetes.Interface,
}
return client.FlowcontrolV1beta1().PriorityLevelConfigurations().Watch(ctx, options)
},
},
}, client),
&apiflowcontrolv1beta1.PriorityLevelConfiguration{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/flowcontrol/v1beta2/flowschema.go
View file

@ -56,7 +56,7 @@ func NewFlowSchemaInformer(client kubernetes.Interface, resyncPeriod time.Durati
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredFlowSchemaInformer(client kubernetes.Interface, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options v1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -81,7 +81,7 @@ func NewFilteredFlowSchemaInformer(client kubernetes.Interface, resyncPeriod tim
}
return client.FlowcontrolV1beta2().FlowSchemas().Watch(ctx, options)
},
},
}, client),
&apiflowcontrolv1beta2.FlowSchema{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/flowcontrol/v1beta2/prioritylevelconfiguration.go
View file

@ -56,7 +56,7 @@ func NewPriorityLevelConfigurationInformer(client kubernetes.Interface, resyncPe
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredPriorityLevelConfigurationInformer(client kubernetes.Interface, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options v1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -81,7 +81,7 @@ func NewFilteredPriorityLevelConfigurationInformer(client kubernetes.Interface,
}
return client.FlowcontrolV1beta2().PriorityLevelConfigurations().Watch(ctx, options)
},
},
}, client),
&apiflowcontrolv1beta2.PriorityLevelConfiguration{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/flowcontrol/v1beta3/flowschema.go
View file

@ -56,7 +56,7 @@ func NewFlowSchemaInformer(client kubernetes.Interface, resyncPeriod time.Durati
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredFlowSchemaInformer(client kubernetes.Interface, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options v1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -81,7 +81,7 @@ func NewFilteredFlowSchemaInformer(client kubernetes.Interface, resyncPeriod tim
}
return client.FlowcontrolV1beta3().FlowSchemas().Watch(ctx, options)
},
},
}, client),
&apiflowcontrolv1beta3.FlowSchema{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/flowcontrol/v1beta3/prioritylevelconfiguration.go
View file

@ -56,7 +56,7 @@ func NewPriorityLevelConfigurationInformer(client kubernetes.Interface, resyncPe
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredPriorityLevelConfigurationInformer(client kubernetes.Interface, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options v1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -81,7 +81,7 @@ func NewFilteredPriorityLevelConfigurationInformer(client kubernetes.Interface,
}
return client.FlowcontrolV1beta3().PriorityLevelConfigurations().Watch(ctx, options)
},
},
}, client),
&apiflowcontrolv1beta3.PriorityLevelConfiguration{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/networking/v1/ingress.go
View file

@ -57,7 +57,7 @@ func NewIngressInformer(client kubernetes.Interface, namespace string, resyncPer
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredIngressInformer(client kubernetes.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options metav1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -82,7 +82,7 @@ func NewFilteredIngressInformer(client kubernetes.Interface, namespace string, r
}
return client.NetworkingV1().Ingresses(namespace).Watch(ctx, options)
},
},
}, client),
&apinetworkingv1.Ingress{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/networking/v1/ingressclass.go
View file

@ -56,7 +56,7 @@ func NewIngressClassInformer(client kubernetes.Interface, resyncPeriod time.Dura
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredIngressClassInformer(client kubernetes.Interface, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options metav1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -81,7 +81,7 @@ func NewFilteredIngressClassInformer(client kubernetes.Interface, resyncPeriod t
}
return client.NetworkingV1().IngressClasses().Watch(ctx, options)
},
},
}, client),
&apinetworkingv1.IngressClass{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/networking/v1/ipaddress.go
View file

@ -56,7 +56,7 @@ func NewIPAddressInformer(client kubernetes.Interface, resyncPeriod time.Duratio
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredIPAddressInformer(client kubernetes.Interface, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options metav1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -81,7 +81,7 @@ func NewFilteredIPAddressInformer(client kubernetes.Interface, resyncPeriod time
}
return client.NetworkingV1().IPAddresses().Watch(ctx, options)
},
},
}, client),
&apinetworkingv1.IPAddress{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/networking/v1/networkpolicy.go
View file

@ -57,7 +57,7 @@ func NewNetworkPolicyInformer(client kubernetes.Interface, namespace string, res
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredNetworkPolicyInformer(client kubernetes.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options metav1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -82,7 +82,7 @@ func NewFilteredNetworkPolicyInformer(client kubernetes.Interface, namespace str
}
return client.NetworkingV1().NetworkPolicies(namespace).Watch(ctx, options)
},
},
}, client),
&apinetworkingv1.NetworkPolicy{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/networking/v1/servicecidr.go
View file

@ -56,7 +56,7 @@ func NewServiceCIDRInformer(client kubernetes.Interface, resyncPeriod time.Durat
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredServiceCIDRInformer(client kubernetes.Interface, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options metav1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -81,7 +81,7 @@ func NewFilteredServiceCIDRInformer(client kubernetes.Interface, resyncPeriod ti
}
return client.NetworkingV1().ServiceCIDRs().Watch(ctx, options)
},
},
}, client),
&apinetworkingv1.ServiceCIDR{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/networking/v1beta1/ingress.go
View file

@ -57,7 +57,7 @@ func NewIngressInformer(client kubernetes.Interface, namespace string, resyncPer
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredIngressInformer(client kubernetes.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options v1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -82,7 +82,7 @@ func NewFilteredIngressInformer(client kubernetes.Interface, namespace string, r
}
return client.NetworkingV1beta1().Ingresses(namespace).Watch(ctx, options)
},
},
}, client),
&apinetworkingv1beta1.Ingress{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/networking/v1beta1/ingressclass.go
View file

@ -56,7 +56,7 @@ func NewIngressClassInformer(client kubernetes.Interface, resyncPeriod time.Dura
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredIngressClassInformer(client kubernetes.Interface, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options v1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -81,7 +81,7 @@ func NewFilteredIngressClassInformer(client kubernetes.Interface, resyncPeriod t
}
return client.NetworkingV1beta1().IngressClasses().Watch(ctx, options)
},
},
}, client),
&apinetworkingv1beta1.IngressClass{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/networking/v1beta1/ipaddress.go
View file

@ -56,7 +56,7 @@ func NewIPAddressInformer(client kubernetes.Interface, resyncPeriod time.Duratio
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredIPAddressInformer(client kubernetes.Interface, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options v1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -81,7 +81,7 @@ func NewFilteredIPAddressInformer(client kubernetes.Interface, resyncPeriod time
}
return client.NetworkingV1beta1().IPAddresses().Watch(ctx, options)
},
},
}, client),
&apinetworkingv1beta1.IPAddress{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/networking/v1beta1/servicecidr.go
View file

@ -56,7 +56,7 @@ func NewServiceCIDRInformer(client kubernetes.Interface, resyncPeriod time.Durat
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredServiceCIDRInformer(client kubernetes.Interface, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options v1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -81,7 +81,7 @@ func NewFilteredServiceCIDRInformer(client kubernetes.Interface, resyncPeriod ti
}
return client.NetworkingV1beta1().ServiceCIDRs().Watch(ctx, options)
},
},
}, client),
&apinetworkingv1beta1.ServiceCIDR{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/node/v1/runtimeclass.go
View file

@ -56,7 +56,7 @@ func NewRuntimeClassInformer(client kubernetes.Interface, resyncPeriod time.Dura
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredRuntimeClassInformer(client kubernetes.Interface, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options metav1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -81,7 +81,7 @@ func NewFilteredRuntimeClassInformer(client kubernetes.Interface, resyncPeriod t
}
return client.NodeV1().RuntimeClasses().Watch(ctx, options)
},
},
}, client),
&apinodev1.RuntimeClass{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/node/v1alpha1/runtimeclass.go
View file

@ -56,7 +56,7 @@ func NewRuntimeClassInformer(client kubernetes.Interface, resyncPeriod time.Dura
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredRuntimeClassInformer(client kubernetes.Interface, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options v1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -81,7 +81,7 @@ func NewFilteredRuntimeClassInformer(client kubernetes.Interface, resyncPeriod t
}
return client.NodeV1alpha1().RuntimeClasses().Watch(ctx, options)
},
},
}, client),
&apinodev1alpha1.RuntimeClass{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/node/v1beta1/runtimeclass.go
View file

@ -56,7 +56,7 @@ func NewRuntimeClassInformer(client kubernetes.Interface, resyncPeriod time.Dura
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredRuntimeClassInformer(client kubernetes.Interface, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options v1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -81,7 +81,7 @@ func NewFilteredRuntimeClassInformer(client kubernetes.Interface, resyncPeriod t
}
return client.NodeV1beta1().RuntimeClasses().Watch(ctx, options)
},
},
}, client),
&apinodev1beta1.RuntimeClass{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/policy/v1/poddisruptionbudget.go
View file

@ -57,7 +57,7 @@ func NewPodDisruptionBudgetInformer(client kubernetes.Interface, namespace strin
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredPodDisruptionBudgetInformer(client kubernetes.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options metav1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -82,7 +82,7 @@ func NewFilteredPodDisruptionBudgetInformer(client kubernetes.Interface, namespa
}
return client.PolicyV1().PodDisruptionBudgets(namespace).Watch(ctx, options)
},
},
}, client),
&apipolicyv1.PodDisruptionBudget{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/policy/v1beta1/poddisruptionbudget.go
View file

@ -57,7 +57,7 @@ func NewPodDisruptionBudgetInformer(client kubernetes.Interface, namespace strin
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredPodDisruptionBudgetInformer(client kubernetes.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options v1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -82,7 +82,7 @@ func NewFilteredPodDisruptionBudgetInformer(client kubernetes.Interface, namespa
}
return client.PolicyV1beta1().PodDisruptionBudgets(namespace).Watch(ctx, options)
},
},
}, client),
&apipolicyv1beta1.PodDisruptionBudget{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/rbac/v1/clusterrole.go
View file

@ -56,7 +56,7 @@ func NewClusterRoleInformer(client kubernetes.Interface, resyncPeriod time.Durat
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredClusterRoleInformer(client kubernetes.Interface, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options metav1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -81,7 +81,7 @@ func NewFilteredClusterRoleInformer(client kubernetes.Interface, resyncPeriod ti
}
return client.RbacV1().ClusterRoles().Watch(ctx, options)
},
},
}, client),
&apirbacv1.ClusterRole{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/rbac/v1/clusterrolebinding.go
View file

@ -56,7 +56,7 @@ func NewClusterRoleBindingInformer(client kubernetes.Interface, resyncPeriod tim
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredClusterRoleBindingInformer(client kubernetes.Interface, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options metav1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -81,7 +81,7 @@ func NewFilteredClusterRoleBindingInformer(client kubernetes.Interface, resyncPe
}
return client.RbacV1().ClusterRoleBindings().Watch(ctx, options)
},
},
}, client),
&apirbacv1.ClusterRoleBinding{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/rbac/v1/role.go
View file

@ -57,7 +57,7 @@ func NewRoleInformer(client kubernetes.Interface, namespace string, resyncPeriod
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredRoleInformer(client kubernetes.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options metav1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -82,7 +82,7 @@ func NewFilteredRoleInformer(client kubernetes.Interface, namespace string, resy
}
return client.RbacV1().Roles(namespace).Watch(ctx, options)
},
},
}, client),
&apirbacv1.Role{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/rbac/v1/rolebinding.go
View file

@ -57,7 +57,7 @@ func NewRoleBindingInformer(client kubernetes.Interface, namespace string, resyn
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredRoleBindingInformer(client kubernetes.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options metav1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -82,7 +82,7 @@ func NewFilteredRoleBindingInformer(client kubernetes.Interface, namespace strin
}
return client.RbacV1().RoleBindings(namespace).Watch(ctx, options)
},
},
}, client),
&apirbacv1.RoleBinding{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/rbac/v1alpha1/clusterrole.go
View file

@ -56,7 +56,7 @@ func NewClusterRoleInformer(client kubernetes.Interface, resyncPeriod time.Durat
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredClusterRoleInformer(client kubernetes.Interface, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options v1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -81,7 +81,7 @@ func NewFilteredClusterRoleInformer(client kubernetes.Interface, resyncPeriod ti
}
return client.RbacV1alpha1().ClusterRoles().Watch(ctx, options)
},
},
}, client),
&apirbacv1alpha1.ClusterRole{},
resyncPeriod,
indexers,

4
staging/src/k8s.io/client-go/informers/rbac/v1alpha1/clusterrolebinding.go
View file

@ -56,7 +56,7 @@ func NewClusterRoleBindingInformer(client kubernetes.Interface, resyncPeriod tim
// one. This reduces memory footprint and number of connections to the server.
func NewFilteredClusterRoleBindingInformer(client kubernetes.Interface, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
return cache.NewSharedIndexInformer(
&cache.ListWatch{
cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{
ListFunc: func(options v1.ListOptions) (runtime.Object, error) {
if tweakListOptions != nil {
tweakListOptions(&options)
@ -81,7 +81,7 @@ func NewFilteredClusterRoleBindingInformer(client kubernetes.Interface, resyncPe
}
return client.RbacV1alpha1().ClusterRoleBindings().Watch(ctx, options)
},
},
}, client),
&apirbacv1alpha1.ClusterRoleBinding{},
resyncPeriod,
indexers,

Some files were not shown because too many files have changed in this diff Show more