- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for ValidateInitialization (0.26 sec)
-
staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/mutating/plugin_test.go
wh.SetExternalKubeClientSet(client) wh.SetExternalKubeInformerFactory(informer) informer.Start(stopCh) informer.WaitForCacheSync(stopCh) if err = wh.ValidateInitialization(); err != nil { b.Errorf("failed to validate initialization: %v", err) return } var attr admission.Attributes if tt.IsCRD {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 06:06:52 UTC 2024 - 11K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/validating/plugin_test.go
wh.SetExternalKubeClientSet(client) wh.SetExternalKubeInformerFactory(informer) informer.Start(stopCh) informer.WaitForCacheSync(stopCh) if err = wh.ValidateInitialization(); err != nil { b.Errorf("%s: failed to validate initialization: %v", tt.Name, err) return } attr := webhooktesting.NewAttribute(ns, nil, tt.IsDryRun) b.ResetTimer()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 06:06:52 UTC 2024 - 11.9K bytes - Viewed (0) -
plugin/pkg/admission/serviceaccount/admission.go
s.serviceAccountLister = serviceAccountInformer.Lister() s.SetReadyFunc(func() bool { return serviceAccountInformer.Informer().HasSynced() }) } // ValidateInitialization ensures an authorizer is set. func (s *Plugin) ValidateInitialization() error { if s.client == nil { return fmt.Errorf("missing client") } if s.serviceAccountLister == nil { return fmt.Errorf("missing serviceAccountLister") }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 12 17:49:30 UTC 2024 - 18.6K bytes - Viewed (0) -
plugin/pkg/admission/gc/gc_admission.go
a.authorizer = authorizer } func (a *gcPermissionsEnforcement) SetRESTMapper(restMapper meta.RESTMapper) { a.restMapper = restMapper } func (a *gcPermissionsEnforcement) ValidateInitialization() error { if a.authorizer == nil { return fmt.Errorf("missing authorizer") } if a.restMapper == nil { return fmt.Errorf("missing restMapper") } return nil
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Sep 05 02:24:38 UTC 2023 - 10.3K bytes - Viewed (0) -
plugin/pkg/admission/limitranger/admission.go
func (l *LimitRanger) SetExternalKubeClientSet(client kubernetes.Interface) { l.client = client } // ValidateInitialization verifies the LimitRanger object has been properly initialized func (l *LimitRanger) ValidateInitialization() error { if l.lister == nil { return fmt.Errorf("missing limitRange lister") } if l.client == nil { return fmt.Errorf("missing client") }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 24 13:04:39 UTC 2023 - 25.8K bytes - Viewed (0) -
plugin/pkg/admission/podtolerationrestriction/admission_test.go
} handler := NewPodTolerationsPlugin(pluginConfig) pluginInitializer := genericadmissioninitializer.New(c, nil, f, nil, nil, nil, nil) pluginInitializer.Initialize(handler) err = admission.ValidateInitialization(handler) return handler, f, err
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 16K bytes - Viewed (0) -
plugin/pkg/admission/noderestriction/admission.go
p.podsGetter = f.Core().V1().Pods().Lister() p.nodesGetter = f.Core().V1().Nodes().Lister() } // ValidateInitialization validates the Plugin was initialized properly func (p *Plugin) ValidateInitialization() error { if p.nodeIdentifier == nil { return fmt.Errorf("%s requires a node identifier", PluginName) } if p.podsGetter == nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 21:22:55 UTC 2024 - 23.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/namespace/lifecycle/admission_test.go
if err != nil { return nil, f, err } pluginInitializer := kubeadmission.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 with the specified phase.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 14.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/generic/policy_test_context.go
fakeAuthorizer{}, featureGate, testContext.Done(), fakeRestMapper, ) genericInitializer.Initialize(plugin) plugin.SetRESTMapper(fakeRestMapper) if err := plugin.ValidateInitialization(); err != nil { testCancel() return nil, nil, err } res := &PolicyTestContext[P, B, E]{ Context: testContext, Plugin: plugin, Source: source,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 19K bytes - Viewed (0)