Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for PluginInitializers (0.26 sec)

  1. staging/src/k8s.io/apiserver/pkg/server/options/admission.go

    // note this method uses:
    //
    //	genericconfig.Authorizer
    func (a *AdmissionOptions) ApplyTo(
    	c *server.Config,
    	informers informers.SharedInformerFactory,
    	kubeClient kubernetes.Interface,
    	dynamicClient dynamic.Interface,
    	features featuregate.FeatureGate,
    	pluginInitializers ...admission.PluginInitializer,
    ) error {
    	if a == nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun May 12 08:49:42 UTC 2024
    - 9.7K bytes
    - Viewed (0)
  2. pkg/kubeapiserver/options/admission.go

    func (a *AdmissionOptions) ApplyTo(
    	c *server.Config,
    	informers informers.SharedInformerFactory,
    	kubeClient kubernetes.Interface,
    	dynamicClient dynamic.Interface,
    	features featuregate.FeatureGate,
    	pluginInitializers ...admission.PluginInitializer,
    ) error {
    	if a == nil {
    		return nil
    	}
    
    	if a.PluginNames != nil {
    		// pass PluginNames to generic AdmissionOptions
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Sep 27 09:22:37 UTC 2023
    - 4.8K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/admission/plugins.go

    	if validater, ok := plugin.(InitializationValidator); ok {
    		err := validater.ValidateInitialization()
    		if err != nil {
    			return err
    		}
    	}
    	return nil
    }
    
    type PluginInitializers []PluginInitializer
    
    func (pp PluginInitializers) Initialize(plugin Interface) {
    	for _, p := range pp {
    		p.Initialize(plugin)
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 29 15:48:39 UTC 2023
    - 6K bytes
    - Viewed (0)
  4. pkg/controlplane/apiserver/apiextensions.go

    	"k8s.io/client-go/informers"
    
    	"k8s.io/kubernetes/pkg/controlplane/apiserver/options"
    )
    
    func CreateAPIExtensionsConfig(
    	kubeAPIServerConfig server.Config,
    	kubeInformers informers.SharedInformerFactory,
    	pluginInitializers []admission.PluginInitializer,
    	commandOptions options.CompletedOptions,
    	masterCount int,
    	serviceResolver webhook.ServiceResolver,
    	authResolverWrapper webhook.AuthenticationInfoResolverWrapper,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 01 18:08:20 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/server/options/recommended.go

    	o.Features.AddFlags(fs)
    	o.CoreAPI.AddFlags(fs)
    	o.Admission.AddFlags(fs)
    	o.EgressSelector.AddFlags(fs)
    	o.Traces.AddFlags(fs)
    }
    
    // ApplyTo adds RecommendedOptions to the server configuration.
    // pluginInitializers can be empty, it is only need for additional initializers.
    func (o *RecommendedOptions) ApplyTo(config *server.RecommendedConfig) error {
    	if err := o.Etcd.ApplyTo(&config.Config); err != nil {
    		return err
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 22 18:51:27 UTC 2024
    - 6K bytes
    - Viewed (0)
  6. pkg/controlplane/apiserver/aggregator.go

    	externalInformers kubeexternalinformers.SharedInformerFactory,
    	serviceResolver aggregatorapiserver.ServiceResolver,
    	proxyTransport *http.Transport,
    	peerProxy utilpeerproxy.Interface,
    	pluginInitializers []admission.PluginInitializer,
    ) (*aggregatorapiserver.Config, error) {
    	// make a shallow copy to let us twiddle a few things
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 01 18:08:20 UTC 2024
    - 15.3K bytes
    - Viewed (0)
  7. plugin/pkg/admission/gc/gc_admission_test.go

    	genericPluginInitializer := initializer.New(nil, nil, nil, fakeAuthorizer{}, nil, nil, restMapper)
    	pluginInitializer := controlplaneadmission.NewPluginInitializer(nil, nil)
    	initializersChain := apiserveradmission.PluginInitializers{}
    	initializersChain = append(initializersChain, genericPluginInitializer)
    	initializersChain = append(initializersChain, pluginInitializer)
    
    	initializersChain.Initialize(gcAdmit)
    	return gcAdmit, nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 21:28:42 UTC 2024
    - 24.5K bytes
    - Viewed (0)
  8. plugin/pkg/admission/resourcequota/admission_test.go

    	}
    	quotaConfiguration := install.NewQuotaConfigurationForAdmission()
    
    	handler, err := resourcequota.NewResourceQuota(config, 5)
    	if err != nil {
    		return nil, err
    	}
    
    	initializers := admission.PluginInitializers{
    		genericadmissioninitializer.New(kubeClient, nil, informerFactory, nil, nil, stopCh, nil),
    		controlplaneadmission.NewPluginInitializer(quotaConfiguration, nil),
    	}
    	initializers.Initialize(handler)
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 21:28:42 UTC 2024
    - 84.1K bytes
    - Viewed (0)
Back to top