- Sort Score
- Result 10 results
- Languages All
Results 41 - 46 of 46 for HandleCrash (0.15 sec)
-
pkg/controller/ttl/ttl_controller.go
{sizeMin: 1800, sizeMax: math.MaxInt32, ttlSeconds: 300}, } ) // 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")
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) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/openapi/controller.go
return c } // Run sets openAPIAggregationManager and starts workers func (c *Controller) Run(staticSpec *spec.Swagger, openAPIService *handler.OpenAPIService, stopCh <-chan struct{}) { defer utilruntime.HandleCrash() defer c.queue.ShutDown() defer klog.Infof("Shutting down OpenAPI controller") klog.Infof("Starting OpenAPI controller") c.staticSpec = staticSpec c.openAPIService = openAPIService
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 9.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/dynamiccertificates/configmap_cafile_content.go
_ = c.loadCABundle() 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/bootstrap/bootstrapsigner.go
options.SecretResync, ) 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)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 9.2K bytes - Viewed (0) -
pkg/controller/volume/ephemeral/controller.go
return } for _, obj := range objs { ec.enqueuePod(obj) } } func (ec *ephemeralController) Run(ctx context.Context, workers int) { defer runtime.HandleCrash() defer ec.queue.ShutDown() logger := klog.FromContext(ctx) logger.Info("Starting ephemeral volume controller") defer logger.Info("Shutting down ephemeral volume controller")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 9.2K bytes - Viewed (0)