- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 44 for ValidateInitialization (0.26 sec)
-
staging/src/k8s.io/apiserver/pkg/admission/interfaces.go
type PluginInitializer interface { Initialize(plugin Interface) } // InitializationValidator holds ValidateInitialization functions, which are responsible for validation of initialized // shared resources and should be implemented on admission plugins type InitializationValidator interface { ValidateInitialization() error } // ConfigProvider provides a way to get configuration for an admission plugin based on its name
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Oct 28 14:03:18 UTC 2021 - 8K bytes - Viewed (0) -
plugin/pkg/admission/podnodeselector/admission.go
namespaceInformer := f.Core().V1().Namespaces() p.namespaceLister = namespaceInformer.Lister() p.SetReadyFunc(namespaceInformer.Informer().HasSynced) } // ValidateInitialization verifies the object has been properly initialized func (p *Plugin) ValidateInitialization() error { if p.namespaceLister == nil { return fmt.Errorf("missing namespaceLister") } if p.client == nil { return fmt.Errorf("missing client") }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 26 17:14:05 UTC 2022 - 8.3K bytes - Viewed (0) -
plugin/pkg/admission/podtolerationrestriction/admission.go
namespaceInformer := f.Core().V1().Namespaces() p.namespaceLister = namespaceInformer.Lister() p.SetReadyFunc(namespaceInformer.Informer().HasSynced) } // ValidateInitialization checks the object is properly initialized func (p *Plugin) ValidateInitialization() error { if p.namespaceLister == nil { return fmt.Errorf("missing namespaceLister") } if p.client == nil { return fmt.Errorf("missing client") }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 29 20:07:59 UTC 2020 - 8.3K bytes - Viewed (0) -
plugin/pkg/admission/runtimeclass/admission.go
r.SetReadyFunc(runtimeClassInformer.Informer().HasSynced) r.runtimeClassLister = runtimeClassInformer.Lister() } // ValidateInitialization implements the WantsExternalKubeInformerFactory interface. func (r *RuntimeClass) ValidateInitialization() error { if r.runtimeClassLister == nil { return fmt.Errorf("missing RuntimeClass lister") } if r.runtimeClassClient == nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 05 05:53:38 UTC 2024 - 8.9K bytes - Viewed (0) -
plugin/pkg/admission/priority/admission.go
func NewPlugin() *Plugin { return &Plugin{ Handler: admission.NewHandler(admission.Create, admission.Update, admission.Delete), } } // ValidateInitialization implements the InitializationValidator interface. func (p *Plugin) ValidateInitialization() error { if p.client == nil { return fmt.Errorf("%s requires a client", PluginName) } if p.lister == nil { return fmt.Errorf("%s requires a lister", PluginName)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Feb 08 10:11:23 UTC 2022 - 9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/namespace/lifecycle/admission.go
func (l *Lifecycle) SetExternalKubeClientSet(client kubernetes.Interface) { l.client = client } // ValidateInitialization implements the InitializationValidator interface. func (l *Lifecycle) ValidateInitialization() error { if l.namespaceLister == nil { return fmt.Errorf("missing namespaceLister") } if l.client == nil { return fmt.Errorf("missing client") }
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
}) } func (a *Webhook) SetAuthorizer(authorizer authorizer.Authorizer) { a.authorizer = authorizer } // ValidateInitialization implements the InitializationValidator interface. func (a *Webhook) ValidateInitialization() error { if a.hookSource == nil { return fmt.Errorf("kubernetes client is not properly setup") } if err := a.namespaceMatcher.Validate(); err != nil {
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/namespace/exists/admission_test.go
handler := NewExists() pluginInitializer := genericadmissioninitializer.New(c, nil, f, nil, nil, nil, nil) pluginInitializer.Initialize(handler) err := admission.ValidateInitialization(handler) return handler, f, err } // newMockClientForTest creates a mock client that returns a client configured for the specified list of namespaces. func newMockClientForTest(namespaces []string) *fake.Clientset {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 4.4K bytes - Viewed (0) -
plugin/pkg/admission/security/podsecurity/admission_test.go
p.SetExternalKubeInformerFactory(informerFactory) stopCh := make(chan struct{}) defer close(stopCh) informerFactory.Start(stopCh) informerFactory.WaitForCacheSync(stopCh) if err := p.ValidateInitialization(); err != nil { b.Fatal(err) } corePod := &core.Pod{} v1Pod := &corev1.Pod{} data, err := ioutil.ReadFile("testdata/pod_restricted.yaml") if err != nil { b.Fatal(err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 15 01:29:47 UTC 2022 - 10.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/resourcequota/admission_test.go
} } } func TestInitializationOrder(t *testing.T) { a := &QuotaAdmission{} qca := generic.NewConfiguration(nil, nil) a.SetQuotaConfiguration(qca) if err := a.ValidateInitialization(); err != stopChUnconfiguredErr { t.Errorf("unexpected error: %v", err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 23 10:34:50 UTC 2022 - 5.2K bytes - Viewed (0)