- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 63 for isShutdown (0.17 sec)
-
staging/src/k8s.io/apiserver/pkg/server/hooks.go
// until it becomes easier to use. type PostStartHookFunc func(context PostStartHookContext) error // PreShutdownHookFunc is a function that can be added to the shutdown logic. type PreShutdownHookFunc func() error // PostStartHookContext provides information about this API server to a PostStartHookFunc type PostStartHookContext struct {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 18:59:21 UTC 2024 - 8K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/nonstructuralschema/nonstructuralschema_controller.go
return nil } // Run starts the controller. func (c *ConditionController) Run(workers int, stopCh <-chan struct{}) { defer utilruntime.HandleCrash() defer c.queue.ShutDown() klog.Infof("Starting NonStructuralSchemaConditionController") defer klog.Infof("Shutting down NonStructuralSchemaConditionController") if !cache.WaitForCacheSync(stopCh, c.crdSynced) { return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 8.3K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/openapiv3/controller.go
return c } // Run sets openAPIAggregationManager and starts workers func (c *Controller) Run(openAPIV3Service *handler3.OpenAPIService, stopCh <-chan struct{}) { defer utilruntime.HandleCrash() defer c.queue.ShutDown() defer klog.Infof("Shutting down OpenAPI V3 controller") klog.Infof("Starting OpenAPI V3 controller") c.openAPIV3Service = openAPIV3Service if !cache.WaitForCacheSync(stopCh, c.crdsSynced) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 7.9K bytes - Viewed (0) -
pkg/controller/namespace/namespace_controller.go
} // Run starts observing the system with the specified number of workers. func (nm *NamespaceController) Run(ctx context.Context, workers int) { defer utilruntime.HandleCrash() defer nm.queue.ShutDown() logger := klog.FromContext(ctx) logger.Info("Starting namespace controller") defer logger.Info("Shutting down namespace controller") if !cache.WaitForNamedCacheSync("namespace", ctx.Done(), nm.listerSynced) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 7.6K bytes - Viewed (0) -
pkg/controller/storageversionmigrator/storageversionmigrator.go
return } svmc.queue.Add(key) } func (svmc *SVMController) Run(ctx context.Context) { defer utilruntime.HandleCrash() defer svmc.queue.ShutDown() logger := klog.FromContext(ctx) logger.Info("Starting", "controller", svmc.controllerName) defer logger.Info("Shutting down", "controller", svmc.controllerName)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 9.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/options/encryptionconfig/controller/controller.go
defer klog.InfoS("Shutting down controller", "name", d.name) var wg sync.WaitGroup wg.Add(1) go func() { defer utilruntime.HandleCrash() defer wg.Done() defer d.queue.ShutDown() <-ctx.Done() }() wg.Add(1) go func() { defer utilruntime.HandleCrash() defer wg.Done() d.runWorker(ctx) }()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 9.5K bytes - Viewed (0) -
pkg/controller/bootstrap/bootstrapsigner.go
) return e, nil } // Run runs controller loops and returns when they are done func (e *Signer) Run(ctx context.Context) { // Shut down queues defer utilruntime.HandleCrash() defer e.syncQueue.ShutDown() if !cache.WaitForNamedCacheSync("bootstrap_signer", ctx.Done(), e.configMapSynced, e.secretSynced) { return } logger := klog.FromContext(ctx) logger.V(5).Info("Starting workers")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 9.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/dynamiccertificates/configmap_cafile_content.go
return nil } // Run starts the kube-apiserver and blocks until stopCh is closed. func (c *ConfigMapCAController) Run(ctx context.Context, workers int) { defer utilruntime.HandleCrash() defer c.queue.ShutDown() klog.InfoS("Starting controller", "name", c.name) defer klog.InfoS("Shutting down controller", "name", c.name) // we have a personal informer that is narrowly scoped, start it.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 8.9K bytes - Viewed (0) -
pkg/controller/ttl/ttl_controller.go
} ) // Run begins watching and syncing. func (ttlc *Controller) Run(ctx context.Context, workers int) { defer utilruntime.HandleCrash() defer ttlc.queue.ShutDown() logger := klog.FromContext(ctx) logger.Info("Starting TTL controller") defer logger.Info("Shutting down TTL controller") if !cache.WaitForNamedCacheSync("TTL", ctx.Done(), ttlc.hasSynced) { return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 8.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/dynamiccertificates/dynamic_cafile_content.go
return c.loadCABundle() } // Run starts the controller and blocks until stopCh is closed. func (c *DynamicFileCAContent) Run(ctx context.Context, workers int) { defer utilruntime.HandleCrash() defer c.queue.ShutDown() klog.InfoS("Starting controller", "name", c.name) defer klog.InfoS("Shutting down controller", "name", c.name) // doesn't matter what workers say, only start one.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 8.4K bytes - Viewed (0)