Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 12 for versionedinformers (0.25 sec)

  1. pkg/controlplane/apiserver/config.go

    	if err != nil {
    		lastErr = fmt.Errorf("failed to create real external clientset: %w", err)
    		return
    	}
    	versionedInformers = clientgoinformers.NewSharedInformerFactory(clientgoExternalClient, 10*time.Minute)
    
    	if lastErr = s.Features.ApplyTo(genericConfig, clientgoExternalClient, versionedInformers); lastErr != nil {
    		return
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 17:57:37 UTC 2024
    - 14.9K bytes
    - Viewed (0)
  2. cmd/kube-apiserver/app/config.go

    	}
    
    	kubeAPIs, serviceResolver, pluginInitializer, err := CreateKubeAPIServerConfig(opts, genericConfig, versionedInformers, storageFactory)
    	if err != nil {
    		return nil, err
    	}
    	c.KubeAPIs = kubeAPIs
    
    	apiExtensions, err := controlplaneapiserver.CreateAPIExtensionsConfig(*kubeAPIs.ControlPlane.Generic, kubeAPIs.ControlPlane.VersionedInformers, pluginInitializer, opts.CompletedOptions, opts.MasterCount,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 01 17:44:20 UTC 2024
    - 3.6K bytes
    - Viewed (0)
  3. pkg/controlplane/apiserver/server.go

    		APIResourceConfigSource:   c.APIResourceConfigSource,
    		RESTOptionsGetter:         c.Generic.RESTOptionsGetter,
    		ClusterAuthenticationInfo: c.ClusterAuthenticationInfo,
    		VersionedInformers:        c.VersionedInformers,
    	}
    
    	client, err := kubernetes.NewForConfig(s.GenericAPIServer.LoopbackClientConfig)
    	if err != nil {
    		return nil, err
    	}
    	if len(c.SystemNamespaces) > 0 {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 19:24:41 UTC 2024
    - 11K bytes
    - Viewed (0)
  4. cmd/kube-apiserver/app/server.go

    	}
    
    	serviceResolver := buildServiceResolver(opts.EnableAggregatorRouting, genericConfig.LoopbackClientConfig.Host, versionedInformers)
    	controlplaneConfig, admissionInitializers, err := controlplaneapiserver.CreateConfig(opts.CompletedOptions, genericConfig, versionedInformers, storageFactory, serviceResolver, kubeInitializers)
    	if err != nil {
    		return nil, nil, nil, err
    	}
    
    	config := &controlplane.Config{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 01 17:44:20 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  5. pkg/controlplane/apiserver/completion.go

    type CompletedConfig struct {
    	*completedConfig
    }
    
    func (c *Config) Complete() CompletedConfig {
    	cfg := completedConfig{
    		c.Generic.Complete(c.VersionedInformers),
    		&c.Extra,
    	}
    
    	discoveryAddresses := discovery.DefaultAddresses{DefaultAddress: cfg.Generic.ExternalAddress}
    	cfg.Generic.DiscoveryAddresses = discoveryAddresses
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 06:13:43 UTC 2024
    - 1.3K bytes
    - Viewed (0)
  6. pkg/kubeapiserver/authorizer/config.go

    	"k8s.io/apiserver/pkg/apis/apiserver/load"
    	"k8s.io/apiserver/pkg/apis/apiserver/validation"
    	"k8s.io/apiserver/pkg/authorization/authorizer"
    	utilfeature "k8s.io/apiserver/pkg/util/feature"
    	versionedinformers "k8s.io/client-go/informers"
    	resourcev1alpha2informers "k8s.io/client-go/informers/resource/v1alpha2"
    	"k8s.io/kubernetes/pkg/auth/authorizer/abac"
    	"k8s.io/kubernetes/pkg/auth/nodeidentifier"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 21:22:55 UTC 2024
    - 8K bytes
    - Viewed (0)
  7. pkg/kubeapiserver/options/authorization.go

    	"k8s.io/apimachinery/pkg/util/sets"
    	"k8s.io/apimachinery/pkg/util/wait"
    	authzconfig "k8s.io/apiserver/pkg/apis/apiserver"
    	genericoptions "k8s.io/apiserver/pkg/server/options"
    	versionedinformers "k8s.io/client-go/informers"
    
    	"k8s.io/kubernetes/pkg/kubeapiserver/authorizer"
    	authzmodes "k8s.io/kubernetes/pkg/kubeapiserver/authorizer/modes"
    )
    
    const (
    	defaultWebhookName                      = "default"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Feb 14 23:09:15 UTC 2024
    - 12K bytes
    - Viewed (0)
  8. pkg/controlplane/apiserver/apis.go

    		ServiceAccountMaxExpiration: c.Extra.ServiceAccountMaxExpiration,
    		APIAudiences:                c.Generic.Authentication.APIAudiences,
    		Informers:                   c.Extra.VersionedInformers,
    	}
    }
    
    // GenericStorageProviders returns a set of APIs for a generic control plane.
    // They ought to be a subset of those served by kube-apiserver.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jun 03 11:50:04 UTC 2024
    - 6.8K bytes
    - Viewed (0)
  9. pkg/controlplane/instance.go

    		ServicePort:               c.Extra.APIServerServicePort,
    		PublicServicePort:         publicServicePort,
    		KubernetesServiceNodePort: c.Extra.KubernetesServiceNodePort,
    	}, client, c.ControlPlane.Extra.VersionedInformers.Core().V1().Services())
    	s.ControlPlane.GenericAPIServer.AddPostStartHookOrDie("bootstrap-controller", func(hookContext genericapiserver.PostStartHookContext) error {
    		kubernetesServiceCtrl.Start(hookContext.StopCh)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jun 03 11:50:04 UTC 2024
    - 21.2K bytes
    - Viewed (0)
  10. pkg/controlplane/instance_test.go

    	clientset, err := kubernetes.NewForConfig(config.ControlPlane.Generic.LoopbackClientConfig)
    	if err != nil {
    		t.Fatalf("unable to create client set due to %v", err)
    	}
    	config.ControlPlane.VersionedInformers = informers.NewSharedInformerFactory(clientset, config.ControlPlane.Generic.LoopbackClientConfig.Timeout)
    
    	return server, *config, assert.New(t)
    }
    
    type fakeLocalhost443Listener struct{}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jun 03 11:50:04 UTC 2024
    - 21.5K bytes
    - Viewed (0)
Back to top