- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for ValidateInitialization (0.29 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/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) -
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) -
plugin/pkg/admission/runtimeclass/admission_test.go
expectError: true, runtimeClass: newRuntimeClassForTest(true, nil, false, nil), }, } for _, tc := range tests { t.Run(tc.name, func(t *testing.T) { err := tc.runtimeClass.ValidateInitialization() if tc.expectError { assert.NotEmpty(t, err) } else { assert.Empty(t, err) } }) } } func TestAdmit(t *testing.T) { runtimeClassName := "runtimeClassName"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 17 01:30:14 UTC 2022 - 17.5K 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)