- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 37 for handleCrash (0.23 sec)
-
pkg/controller/statefulset/stateful_set.go
// TODO: Watch volumes return ssc } // Run runs the statefulset controller. func (ssc *StatefulSetController) Run(ctx context.Context, workers int) { defer utilruntime.HandleCrash() // Start events processing pipeline. ssc.eventBroadcaster.StartStructuredLogging(3) ssc.eventBroadcaster.StartRecordingToSink(&v1core.EventSinkImpl{Interface: ssc.kubeClient.CoreV1().Events("")})
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 18.5K bytes - Viewed (0) -
pkg/controller/resourcequota/resource_quota_controller.go
return } } } } // Run begins quota controller using the specified number of workers func (rq *Controller) Run(ctx context.Context, workers int) { defer utilruntime.HandleCrash() defer rq.queue.ShutDown() defer rq.missingUsageQueue.ShutDown() logger := klog.FromContext(ctx) logger.Info("Starting resource quota controller")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 21.3K bytes - Viewed (0) -
pkg/kubelet/volumemanager/volume_manager.go
intreeToCSITranslator csimigration.InTreeToCSITranslator } func (vm *volumeManager) Run(sourcesReady config.SourcesReady, stopCh <-chan struct{}) { defer runtime.HandleCrash() if vm.kubeClient != nil { // start informer for CSIDriver go vm.volumePluginMgr.Run(stopCh) } go vm.desiredStateOfWorldPopulator.Run(sourcesReady, stopCh)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 21.5K bytes - Viewed (0) -
pkg/controller/endpointslice/endpointslice_controller.go
// to enable TopologyAwareHints. topologyCache *topologycache.TopologyCache } // 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: Tue Jun 04 08:33:32 UTC 2024 - 23.6K bytes - Viewed (0) -
pkg/controller/deployment/deployment_controller.go
dc.podListerSynced = podInformer.Informer().HasSynced return dc, nil } // Run begins watching and syncing. func (dc *DeploymentController) Run(ctx context.Context, workers int) { defer utilruntime.HandleCrash() // Start events processing pipeline. dc.eventBroadcaster.StartStructuredLogging(3) dc.eventBroadcaster.StartRecordingToSink(&v1core.EventSinkImpl{Interface: dc.client.CoreV1().Events("")})
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 24.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/resourcequota/controller.go
// effectively started. go evaluator.shutdownOnStop() return evaluator } // start begins watching and syncing. func (e *quotaEvaluator) start() { defer utilruntime.HandleCrash() for i := 0; i < e.workers; i++ { go wait.Until(e.doWork, time.Second, e.stopCh) } } func (e *quotaEvaluator) shutdownOnStop() { <-e.stopCh klog.Infof("Shutting down quota evaluator")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 25.8K bytes - Viewed (0) -
pilot/pkg/networking/core/envoyfilter/listener_patch.go
func ApplyListenerPatches( patchContext networking.EnvoyFilter_PatchContext, efw *model.EnvoyFilterWrapper, lis []*listener.Listener, skipAdds bool, ) (out []*listener.Listener) { defer runtime.HandleCrash(runtime.LogPanic, func(any) { IncrementEnvoyFilterErrorMetric(Listener) log.Errorf("listeners patch %s/%s caused panic, so the patches did not take effect", efw.Namespace, efw.Name) })
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 17 15:39:29 UTC 2024 - 26.7K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/pv_controller_base.go
ctrl.volumeQueue.Add(volumeName) } // Run starts all of this controller's control loops func (ctrl *PersistentVolumeController) Run(ctx context.Context) { defer utilruntime.HandleCrash() defer ctrl.claimQueue.ShutDown() defer ctrl.volumeQueue.ShutDown() // Start events processing pipeline. ctrl.eventBroadcaster.StartStructuredLogging(3)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 08:42:31 UTC 2024 - 29.5K bytes - Viewed (0) -
pkg/volume/csi/csi_plugin.go
klog.Warning("Skipping CSINode initialization, kubelet running in standalone mode") return nil } kvh.SetKubeletError(errors.New("CSINode is not yet initialized")) go func() { defer utilruntime.HandleCrash() // First wait indefinitely to talk to Kube APIServer nodeName := host.GetNodeName() err := waitForAPIServerForever(kubeClient, nodeName) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 29.2K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/attach_detach_controller.go
// intreeToCSITranslator translates from in-tree volume specs to CSI intreeToCSITranslator csimigration.InTreeToCSITranslator } func (adc *attachDetachController) Run(ctx context.Context) { defer runtime.HandleCrash() defer adc.pvcQueue.ShutDown() // Start events processing pipeline. adc.broadcaster.StartStructuredLogging(3)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 32.6K bytes - Viewed (0)