- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 20 for WantsExternalKubeInformerFactory (0.63 sec)
-
plugin/pkg/admission/namespace/exists/admission.go
*admission.Handler client kubernetes.Interface namespaceLister corev1listers.NamespaceLister } var _ admission.ValidationInterface = &Exists{} var _ = genericadmissioninitializer.WantsExternalKubeInformerFactory(&Exists{}) var _ = genericadmissioninitializer.WantsExternalKubeClientSet(&Exists{}) // Validate makes an admission decision based on the request attributes
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Feb 08 02:16:47 UTC 2020 - 3.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/initializer/interfaces.go
type WantsExternalKubeClientSet interface { SetExternalKubeClientSet(kubernetes.Interface) admission.InitializationValidator } // WantsExternalKubeInformerFactory defines a function which sets InformerFactory for admission plugins that need it type WantsExternalKubeInformerFactory interface { SetExternalKubeInformerFactory(informers.SharedInformerFactory) admission.InitializationValidator }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 05 19:11:10 UTC 2024 - 3.6K bytes - Viewed (0) -
plugin/pkg/admission/runtimeclass/admission.go
runtimeClassClient nodev1client.RuntimeClassInterface } var _ admission.MutationInterface = &RuntimeClass{} var _ admission.ValidationInterface = &RuntimeClass{} var _ genericadmissioninitailizer.WantsExternalKubeInformerFactory = &RuntimeClass{} var _ genericadmissioninitailizer.WantsExternalKubeClientSet = &RuntimeClass{} // SetExternalKubeClientSet sets the client for the plugin
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 05 05:53:38 UTC 2024 - 8.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/initializer/initializer_test.go
if wantExternalKubeClientSet.cs != cs { t.Errorf("expected clientset to be initialized") } } // TestWantsExternalKubeInformerFactory ensures that the informer factory is injected // when the WantsExternalKubeInformerFactory interface is implemented by a plugin. func TestWantsExternalKubeInformerFactory(t *testing.T) { cs := &fake.Clientset{} sf := informers.NewSharedInformerFactory(cs, time.Duration(1)*time.Second)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 8.2K bytes - Viewed (0) -
plugin/pkg/admission/namespace/autoprovision/admission.go
*admission.Handler client kubernetes.Interface namespaceLister corev1listers.NamespaceLister } var _ admission.MutationInterface = &Provision{} var _ = genericadmissioninitializer.WantsExternalKubeInformerFactory(&Provision{}) var _ = genericadmissioninitializer.WantsExternalKubeClientSet(&Provision{}) // Admit makes an admission decision based on the request attributes
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Feb 08 17:30:21 UTC 2020 - 4.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/initializer/initializer.go
wants.SetExternalKubeClientSet(i.externalClient) } if wants, ok := plugin.(WantsDynamicClient); ok { wants.SetDynamicClient(i.dynamicClient) } if wants, ok := plugin.(WantsExternalKubeInformerFactory); ok { wants.SetExternalKubeInformerFactory(i.externalInformers) } if wants, ok := plugin.(WantsAuthorizer); ok { wants.SetAuthorizer(i.authorizer) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 3K bytes - Viewed (0) -
plugin/pkg/admission/storage/persistentvolume/resize/admission.go
return plugin, nil }) } var _ admission.Interface = &persistentVolumeClaimResize{} var _ admission.ValidationInterface = &persistentVolumeClaimResize{} var _ = genericadmissioninitializer.WantsExternalKubeInformerFactory(&persistentVolumeClaimResize{}) type persistentVolumeClaimResize struct { *admission.Handler scLister storagev1listers.StorageClassLister } func newPlugin() *persistentVolumeClaimResize {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 20 15:11:00 UTC 2019 - 3.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/namespace/lifecycle/admission.go
// if a namespace is in this cache, then we will ignore our local state and always fetch latest from api server. forceLiveLookupCache *utilcache.LRUExpireCache } var _ = initializer.WantsExternalKubeInformerFactory(&Lifecycle{}) var _ = initializer.WantsExternalKubeClientSet(&Lifecycle{}) // Admit makes an admission decision based on the request attributes
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 15 09:52:18 UTC 2021 - 8.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/generic/webhook.go
} // SetExternalKubeClientSet implements the WantsExternalKubeInformerFactory interface. // It sets external ClientSet for admission plugins that need it func (a *Webhook) SetExternalKubeClientSet(client clientset.Interface) { a.namespaceMatcher.Client = client } // SetExternalKubeInformerFactory implements the WantsExternalKubeInformerFactory interface.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 22:07:40 UTC 2024 - 9.3K bytes - Viewed (0) -
plugin/pkg/admission/storage/storageclass/setdefault/admission.go
lister storagev1listers.StorageClassLister } var _ admission.Interface = &claimDefaulterPlugin{} var _ admission.MutationInterface = &claimDefaulterPlugin{} var _ = genericadmissioninitializer.WantsExternalKubeInformerFactory(&claimDefaulterPlugin{}) // newPlugin creates a new admission plugin. func newPlugin() *claimDefaulterPlugin { return &claimDefaulterPlugin{ Handler: admission.NewHandler(admission.Create), } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 02 18:52:04 UTC 2022 - 3.4K bytes - Viewed (0)