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