- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 103 for handleCrash (0.28 sec)
-
pkg/kubelet/prober/worker.go
// Returns whether the worker should continue. func (w *worker) doProbe(ctx context.Context) (keepGoing bool) { defer func() { recover() }() // Actually eat panics (HandleCrash takes care of logging) defer runtime.HandleCrash(func(_ interface{}) { keepGoing = true }) startTime := time.Now() status, ok := w.probeManager.statusManager.GetPodStatus(w.pod.UID) if !ok {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jul 27 01:28:06 UTC 2023 - 10.7K bytes - Viewed (0) -
pkg/controller/validatingadmissionpolicystatus/controller.go
// Types of object are calculated from policy.Spec.MatchingConstraints typeChecker *validatingadmissionpolicy.TypeChecker } func (c *Controller) Run(ctx context.Context, workers int) { defer utilruntime.HandleCrash() if !cache.WaitForNamedCacheSync(ControllerName, ctx.Done(), c.policySynced) { return } defer c.policyQueue.ShutDown() for i := 0; i < workers; i++ {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 5.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/value/encrypt/envelope/grpc_service.go
if err != nil { return nil, fmt.Errorf("failed to create connection to %s, error: %v", endpoint, err) } s.kmsClient = kmsapi.NewKeyManagementServiceClient(s.connection) go func() { defer utilruntime.HandleCrash() <-ctx.Done() _ = s.connection.Close() }() return s, nil } func (g *gRPCService) checkAPIVersion(ctx context.Context) error { g.mux.Lock() defer g.mux.Unlock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 27 00:47:46 UTC 2023 - 4.4K bytes - Viewed (0) -
pkg/controller/resourcequota/resource_quota_monitor.go
} // Run sets the stop channel and starts monitor execution until stopCh is // closed. Any running monitors will be stopped before Run returns. func (qm *QuotaMonitor) Run(ctx context.Context) { defer utilruntime.HandleCrash() logger := klog.FromContext(ctx) logger.Info("QuotaMonitor running") defer logger.Info("QuotaMonitor stopping") // Set up the stop channel. qm.monitorLock.Lock() qm.stopCh = ctx.Done()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 11.6K bytes - Viewed (0) -
pkg/controlplane/controller/legacytokentracking/controller.go
}) return c } func (c *Controller) enqueue() { c.queue.Add(queueKey) } // Run starts the controller sync loop. func (c *Controller) Run(stopCh <-chan struct{}) { defer utilruntime.HandleCrash() defer c.queue.ShutDown() klog.Info("Starting legacy_token_tracking_controller") defer klog.Infof("Shutting down legacy_token_tracking_controller") go c.configMapInformer.Run(stopCh)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6K bytes - Viewed (0) -
pkg/controller/nodeipam/node_ipam_controller.go
return ic, nil } // Run starts an asynchronous loop that monitors the status of cluster nodes. func (nc *Controller) Run(ctx context.Context) { defer utilruntime.HandleCrash() // Start event processing pipeline. nc.eventBroadcaster.StartStructuredLogging(3) nc.eventBroadcaster.StartRecordingToSink(&v1core.EventSinkImpl{Interface: nc.kubeClient.CoreV1().Events("")})
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 16:18:38 UTC 2024 - 5.4K bytes - Viewed (0) -
pkg/controller/certificates/certificate_controller.go
return cc } // Run the main goroutine responsible for watching and syncing jobs. func (cc *CertificateController) Run(ctx context.Context, workers int) { defer utilruntime.HandleCrash() defer cc.queue.ShutDown() logger := klog.FromContext(ctx) logger.Info("Starting certificate controller", "name", cc.name) defer logger.Info("Shutting down certificate controller", "name", cc.name)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6.4K bytes - Viewed (0) -
pkg/controller/certificates/rootcacertpublisher/publisher.go
nsListerSynced cache.InformerSynced queue workqueue.TypedRateLimitingInterface[string] } // Run starts process func (c *Publisher) Run(ctx context.Context, workers int) { defer utilruntime.HandleCrash() defer c.queue.ShutDown() logger := klog.FromContext(ctx) logger.Info("Starting root CA cert publisher controller") defer logger.Info("Shutting down root CA cert publisher controller")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6.8K bytes - Viewed (0) -
pilot/pkg/networking/core/envoyfilter/cluster_patch.go
func ApplyClusterMerge(pctx networking.EnvoyFilter_PatchContext, efw *model.EnvoyFilterWrapper, c *cluster.Cluster, hosts []host.Name, ) (out *cluster.Cluster) { defer runtime.HandleCrash(runtime.LogPanic, func(any) { log.Errorf("clusters patch %s/%s caused panic, so the patches did not take effect", efw.Namespace, efw.Name) IncrementEnvoyFilterErrorMetric(Cluster) })
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 17:09:02 UTC 2024 - 6.8K bytes - Viewed (0) -
pkg/controller/bootstrap/tokencleaner.go
}, }, options.SecretResync, ) return e, nil } // Run runs controller loops and returns when they are done func (tc *TokenCleaner) Run(ctx context.Context) { defer utilruntime.HandleCrash() defer tc.queue.ShutDown() logger := klog.FromContext(ctx) logger.Info("Starting token cleaner controller") defer logger.Info("Shutting down token cleaner controller")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6.3K bytes - Viewed (0)