Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 44 for ValidateInitialization (0.26 sec)

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