Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 11 for ValidateInitialization (0.33 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top