- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for DrainedNotify (0.15 sec)
-
staging/src/k8s.io/apiserver/pkg/server/options/etcd.go
healthCheck, err := storagefactory.CreateHealthCheck(s.StorageConfig, c.DrainedNotify()) if err != nil { return err } c.AddHealthChecks(healthz.NamedCheck("etcd", func(r *http.Request) error { return healthCheck() })) readyCheck, err := storagefactory.CreateReadyCheck(s.StorageConfig, c.DrainedNotify()) if err != nil { return err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 15:02:16 UTC 2024 - 20K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/options/admission.go
discoveryRESTMapper := restmapper.NewDeferredDiscoveryRESTMapper(discoveryClient) genericInitializer := initializer.New(kubeClient, dynamicClient, informers, c.Authorization.Authorizer, features, c.DrainedNotify(), discoveryRESTMapper) initializersChain := admission.PluginInitializers{genericInitializer} initializersChain = append(initializersChain, pluginInitializers...)
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/controlplane/apiserver/config.go
if lastErr = s.Etcd.ApplyWithStorageFactoryTo(storageFactory, genericConfig); lastErr != nil { return } ctx := wait.ContextForChannel(genericConfig.DrainedNotify()) // Authentication.ApplyTo requires already applied OpenAPIConfig and EgressSelector if present
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 17:57:37 UTC 2024 - 14.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/config.go
config.Info.Version = strings.Split(version.String(), "-")[0] } else { config.Info.Version = "unversioned" } } } // DrainedNotify returns a lifecycle signal of genericapiserver already drained while shutting down. func (c *Config) DrainedNotify() <-chan struct{} { return c.lifecycleSignals.InFlightRequestsDrained.Signaled() }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 28 08:48:22 UTC 2024 - 47.7K bytes - Viewed (0)