- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for PluginInitializers (0.2 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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)