Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for NewPluginInitializer (0.28 sec)

  1. pkg/controlplane/apiserver/admission/config.go

    	webhookAuthResolverWrapper := webhook.NewDefaultAuthenticationInfoResolverWrapper(proxyTransport, egressSelector, c.LoopbackClientConfig, tp)
    	webhookPluginInitializer := webhookinit.NewPluginInitializer(webhookAuthResolverWrapper, serviceResolver)
    
    	kubePluginInitializer := NewPluginInitializer(
    		quotainstall.NewQuotaConfigurationForAdmission(),
    		exclusion.Excluded(),
    	)
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 21:28:42 UTC 2024
    - 2K bytes
    - Viewed (0)
  2. pkg/kubeapiserver/admission/initializer.go

    type PluginInitializer struct {
    	cloudConfig []byte
    }
    
    var _ admission.PluginInitializer = &PluginInitializer{}
    
    // NewPluginInitializer constructs new instance of PluginInitializer
    func NewPluginInitializer(cloudConfig []byte) *PluginInitializer {
    	return &PluginInitializer{
    		cloudConfig: cloudConfig,
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 21:28:42 UTC 2024
    - 1.5K bytes
    - Viewed (0)
  3. pkg/controlplane/apiserver/admission/initializer.go

    	quotaConfiguration         quota.Configuration
    	excludedAdmissionResources []schema.GroupResource
    }
    
    var _ admission.PluginInitializer = &PluginInitializer{}
    
    // NewPluginInitializer constructs new instance of PluginInitializer
    func NewPluginInitializer(
    	quotaConfiguration quota.Configuration,
    	excludedAdmissionResources []schema.GroupResource,
    ) *PluginInitializer {
    	return &PluginInitializer{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 21:28:42 UTC 2024
    - 1.8K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/initializer/initializer.go

    	authenticationInfoResolverWrapper webhook.AuthenticationInfoResolverWrapper
    }
    
    var _ admission.PluginInitializer = &PluginInitializer{}
    
    // NewPluginInitializer constructs new instance of PluginInitializer
    func NewPluginInitializer(
    	authenticationInfoResolverWrapper webhook.AuthenticationInfoResolverWrapper,
    	serviceResolver webhook.ServiceResolver,
    ) *PluginInitializer {
    	return &PluginInitializer{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 08 07:19:52 UTC 2019
    - 2.6K bytes
    - Viewed (0)
  5. pkg/kubeapiserver/admission/config.go

    		cloudConfig, err = os.ReadFile(c.CloudConfigFile)
    		if err != nil {
    			klog.Fatalf("Error reading from cloud configuration file %s: %#v", c.CloudConfigFile, err)
    		}
    	}
    
    	return []admission.PluginInitializer{NewPluginInitializer(cloudConfig)}, nil
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 21:28:42 UTC 2024
    - 1.2K bytes
    - Viewed (0)
  6. pkg/kubeapiserver/admission/initializer_test.go

    	p.cloudConfig = cloudConfig
    }
    
    func TestCloudConfigAdmissionPlugin(t *testing.T) {
    	cloudConfig := []byte("cloud-configuration")
    	initializer := NewPluginInitializer(cloudConfig)
    	wantsCloudConfigAdmission := &WantsCloudConfigAdmissionPlugin{}
    	initializer.Initialize(wantsCloudConfigAdmission)
    
    	if wantsCloudConfigAdmission.cloudConfig == nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 21:28:42 UTC 2024
    - 1.5K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/initializer/initializer_test.go

    }
    
    func (s *serviceWanter) SetServiceResolver(sr webhook.ServiceResolver) { s.got = sr }
    
    func TestWantsServiceResolver(t *testing.T) {
    	sw := &serviceWanter{}
    	fsr := &fakeServiceResolver{}
    	i := NewPluginInitializer(nil, fsr)
    	i.Initialize(sw)
    	if got, ok := sw.got.(*fakeServiceResolver); !ok || got != fsr {
    		t.Errorf("plumbing fail - %v %v#", ok, got)
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 08 07:19:52 UTC 2019
    - 1.4K bytes
    - Viewed (0)
  8. pkg/controlplane/apiserver/admission/initializer_test.go

    	p.config = config
    }
    
    func TestQuotaConfigurationAdmissionPlugin(t *testing.T) {
    	config := doNothingQuotaConfiguration{}
    	initializer := NewPluginInitializer(config, nil)
    	wantsQuotaConfigurationAdmission := &WantsQuotaConfigurationAdmissionPlugin{}
    	initializer.Initialize(wantsQuotaConfigurationAdmission)
    
    	if wantsQuotaConfigurationAdmission.config == nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 21:28:42 UTC 2024
    - 2K bytes
    - Viewed (0)
  9. plugin/pkg/admission/gc/gc_admission_test.go

    	}
    	restMapper := restmapper.NewDiscoveryRESTMapper(restMapperRes)
    	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)
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 21:28:42 UTC 2024
    - 24.5K bytes
    - Viewed (0)
  10. plugin/pkg/admission/resourcequota/admission_test.go

    	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)
    
    	return handler, admission.ValidateInitialization(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