- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 106 for HandleCrash (0.2 sec)
-
pkg/controlplane/controller/clusterauthenticationtrust/cluster_authentication_trust_controller.go
func (c *Controller) Enqueue() { c.queue.Add(keyFn()) } // Run the controller until stopped. func (c *Controller) Run(ctx context.Context, workers int) { defer utilruntime.HandleCrash() // make sure the work queue is shutdown which will trigger workers to end defer c.queue.ShutDown() klog.Infof("Starting cluster_authentication_trust_controller controller")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 18.2K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/wait/backoff.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 19:14:11 UTC 2023 - 16.5K bytes - Viewed (0) -
pkg/controller/volume/pvcprotection/pvc_protection_controller.go
e.podAddedDeletedUpdated(logger, old, new, false) }, }) return e, nil } // Run runs the controller goroutines. func (c *Controller) Run(ctx context.Context, workers int) { defer utilruntime.HandleCrash() defer c.queue.ShutDown() logger := klog.FromContext(ctx) logger.Info("Starting PVC protection controller") defer logger.Info("Shutting down PVC protection controller")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 14K bytes - Viewed (0) -
pkg/controller/volume/expand/expand_controller.go
return detailedErr } // TODO make concurrency configurable (workers argument). previously, nestedpendingoperations spawned unlimited goroutines func (expc *expandController) Run(ctx context.Context) { defer runtime.HandleCrash() defer expc.queue.ShutDown() logger := klog.FromContext(ctx) logger.Info("Starting expand controller") defer logger.Info("Shutting down expand controller")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 16.2K bytes - Viewed (0) -
pkg/controller/tainteviction/taint_eviction.go
} return tm, nil } // Run starts the controller which will run in loop until `stopCh` is closed. func (tc *Controller) Run(ctx context.Context) { defer utilruntime.HandleCrash() logger := klog.FromContext(ctx) logger.Info("Starting", "controller", tc.name) defer logger.Info("Shutting down controller", "controller", tc.name) // Start events processing pipeline.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 19.9K bytes - Viewed (0) -
pilot/pkg/leaderelection/k8sleaderelection/leaderelection.go
// Run starts the leader election loop. Run will not return // before leader election loop is stopped by ctx or it has // stopped holding the leader lease func (le *LeaderElector) Run(ctx context.Context) { defer runtime.HandleCrash() defer func() { le.config.Callbacks.OnStoppedLeading() }() if !le.acquire(ctx) { return // ctx signaled done } ctx, cancel := context.WithCancel(ctx) defer cancel()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jul 24 04:04:42 UTC 2023 - 16.3K bytes - Viewed (0) -
pkg/controller/servicecidrs/servicecidrs_controller.go
muTree sync.Mutex tree *iptree.Tree[sets.Set[string]] } // Run will not return until stopCh is closed. func (c *Controller) Run(ctx context.Context, workers int) { defer utilruntime.HandleCrash() defer c.queue.ShutDown() c.eventBroadcaster.StartStructuredLogging(3) c.eventBroadcaster.StartRecordingToSink(&v1core.EventSinkImpl{Interface: c.client.CoreV1().Events("")}) defer c.eventBroadcaster.Shutdown()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 18K bytes - Viewed (0) -
pkg/controller/nodeipam/ipam/range_allocator.go
if err == nil { ra.queue.Add(key) } }, }) return ra, nil } func (r *rangeAllocator) Run(ctx context.Context) { defer utilruntime.HandleCrash() // Start event processing pipeline. r.broadcaster.StartStructuredLogging(3) logger := klog.FromContext(ctx) logger.Info("Sending events to api server")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 10:06:15 UTC 2024 - 16.2K bytes - Viewed (0) -
pkg/controller/endpointslicemirroring/endpointslicemirroring_controller.go
endpointUpdatesBatchPeriod time.Duration } // Run will not return until stopCh is closed. func (c *Controller) Run(ctx context.Context, workers int) { defer utilruntime.HandleCrash() // Start events processing pipeline. c.eventBroadcaster.StartLogging(klog.Infof) c.eventBroadcaster.StartRecordingToSink(&v1core.EventSinkImpl{Interface: c.client.CoreV1().Events("")})
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 06 23:18:31 UTC 2024 - 20.1K bytes - Viewed (0) -
pkg/controller/serviceaccount/tokens_controller.go
maxRetries int } // Run runs controller blocks until stopCh is closed func (e *TokensController) Run(ctx context.Context, workers int) { // Shut down queues defer utilruntime.HandleCrash() defer e.syncServiceAccountQueue.ShutDown() defer e.syncSecretQueue.ShutDown() if !cache.WaitForNamedCacheSync("tokens", ctx.Done(), e.serviceAccountSynced, e.secretSynced) { return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 20.5K bytes - Viewed (0)