Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 20 for WantsExternalKubeInformerFactory (0.63 sec)

  1. plugin/pkg/admission/namespace/exists/admission.go

    	*admission.Handler
    	client          kubernetes.Interface
    	namespaceLister corev1listers.NamespaceLister
    }
    
    var _ admission.ValidationInterface = &Exists{}
    var _ = genericadmissioninitializer.WantsExternalKubeInformerFactory(&Exists{})
    var _ = genericadmissioninitializer.WantsExternalKubeClientSet(&Exists{})
    
    // Validate makes an admission decision based on the request attributes
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Feb 08 02:16:47 UTC 2020
    - 3.9K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/admission/initializer/interfaces.go

    type WantsExternalKubeClientSet interface {
    	SetExternalKubeClientSet(kubernetes.Interface)
    	admission.InitializationValidator
    }
    
    // WantsExternalKubeInformerFactory defines a function which sets InformerFactory for admission plugins that need it
    type WantsExternalKubeInformerFactory interface {
    	SetExternalKubeInformerFactory(informers.SharedInformerFactory)
    	admission.InitializationValidator
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 05 19:11:10 UTC 2024
    - 3.6K bytes
    - Viewed (0)
  3. plugin/pkg/admission/runtimeclass/admission.go

    	runtimeClassClient nodev1client.RuntimeClassInterface
    }
    
    var _ admission.MutationInterface = &RuntimeClass{}
    var _ admission.ValidationInterface = &RuntimeClass{}
    
    var _ genericadmissioninitailizer.WantsExternalKubeInformerFactory = &RuntimeClass{}
    var _ genericadmissioninitailizer.WantsExternalKubeClientSet = &RuntimeClass{}
    
    // SetExternalKubeClientSet sets the client for the plugin
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 05 05:53:38 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/pkg/admission/initializer/initializer_test.go

    	if wantExternalKubeClientSet.cs != cs {
    		t.Errorf("expected clientset to be initialized")
    	}
    }
    
    // TestWantsExternalKubeInformerFactory ensures that the informer factory is injected
    // when the WantsExternalKubeInformerFactory interface is implemented by a plugin.
    func TestWantsExternalKubeInformerFactory(t *testing.T) {
    	cs := &fake.Clientset{}
    	sf := informers.NewSharedInformerFactory(cs, time.Duration(1)*time.Second)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 06 00:00:21 UTC 2024
    - 8.2K bytes
    - Viewed (0)
  5. plugin/pkg/admission/namespace/autoprovision/admission.go

    	*admission.Handler
    	client          kubernetes.Interface
    	namespaceLister corev1listers.NamespaceLister
    }
    
    var _ admission.MutationInterface = &Provision{}
    var _ = genericadmissioninitializer.WantsExternalKubeInformerFactory(&Provision{})
    var _ = genericadmissioninitializer.WantsExternalKubeClientSet(&Provision{})
    
    // Admit makes an admission decision based on the request attributes
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Feb 08 17:30:21 UTC 2020
    - 4.1K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiserver/pkg/admission/initializer/initializer.go

    		wants.SetExternalKubeClientSet(i.externalClient)
    	}
    
    	if wants, ok := plugin.(WantsDynamicClient); ok {
    		wants.SetDynamicClient(i.dynamicClient)
    	}
    
    	if wants, ok := plugin.(WantsExternalKubeInformerFactory); ok {
    		wants.SetExternalKubeInformerFactory(i.externalInformers)
    	}
    
    	if wants, ok := plugin.(WantsAuthorizer); ok {
    		wants.SetAuthorizer(i.authorizer)
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 06 00:00:21 UTC 2024
    - 3K bytes
    - Viewed (0)
  7. plugin/pkg/admission/storage/persistentvolume/resize/admission.go

    		return plugin, nil
    	})
    }
    
    var _ admission.Interface = &persistentVolumeClaimResize{}
    var _ admission.ValidationInterface = &persistentVolumeClaimResize{}
    var _ = genericadmissioninitializer.WantsExternalKubeInformerFactory(&persistentVolumeClaimResize{})
    
    type persistentVolumeClaimResize struct {
    	*admission.Handler
    
    	scLister storagev1listers.StorageClassLister
    }
    
    func newPlugin() *persistentVolumeClaimResize {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Aug 20 15:11:00 UTC 2019
    - 3.9K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiserver/pkg/admission/plugin/namespace/lifecycle/admission.go

    	// if a namespace is in this cache, then we will ignore our local state and always fetch latest from api server.
    	forceLiveLookupCache *utilcache.LRUExpireCache
    }
    
    var _ = initializer.WantsExternalKubeInformerFactory(&Lifecycle{})
    var _ = initializer.WantsExternalKubeClientSet(&Lifecycle{})
    
    // Admit makes an admission decision based on the request attributes
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Sep 15 09:52:18 UTC 2021
    - 8.6K bytes
    - Viewed (0)
  9. staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/generic/webhook.go

    }
    
    // SetExternalKubeClientSet implements the WantsExternalKubeInformerFactory interface.
    // It sets external ClientSet for admission plugins that need it
    func (a *Webhook) SetExternalKubeClientSet(client clientset.Interface) {
    	a.namespaceMatcher.Client = client
    }
    
    // SetExternalKubeInformerFactory implements the WantsExternalKubeInformerFactory interface.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 10 22:07:40 UTC 2024
    - 9.3K bytes
    - Viewed (0)
  10. plugin/pkg/admission/storage/storageclass/setdefault/admission.go

    	lister storagev1listers.StorageClassLister
    }
    
    var _ admission.Interface = &claimDefaulterPlugin{}
    var _ admission.MutationInterface = &claimDefaulterPlugin{}
    var _ = genericadmissioninitializer.WantsExternalKubeInformerFactory(&claimDefaulterPlugin{})
    
    // newPlugin creates a new admission plugin.
    func newPlugin() *claimDefaulterPlugin {
    	return &claimDefaulterPlugin{
    		Handler: admission.NewHandler(admission.Create),
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Aug 02 18:52:04 UTC 2022
    - 3.4K bytes
    - Viewed (0)
Back to top