Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for ValidateInitialization (0.26 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/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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
Back to top