- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for StartRecordingToSink (0.17 sec)
-
cmd/kube-scheduler/app/server.go
cz.Set(cc.ComponentConfig) } else { return fmt.Errorf("unable to register configz: %s", err) } // Start events processing pipeline. cc.EventBroadcaster.StartRecordingToSink(ctx.Done()) defer cc.EventBroadcaster.Shutdown() // Setup healthz checks. var checks, readyzChecks []healthz.HealthChecker if cc.ComponentConfig.LeaderElection.LeaderElect {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 27 19:11:24 UTC 2024 - 14.3K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set.go
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("")}) defer ssc.eventBroadcaster.Shutdown() defer ssc.queue.ShutDown() logger := klog.FromContext(ctx)
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/endpointslice/endpointslice_controller.go
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("")}) defer c.eventBroadcaster.Shutdown() defer c.serviceQueue.ShutDown() defer c.topologyQueue.ShutDown() logger := klog.FromContext(ctx)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 08:33:32 UTC 2024 - 23.6K bytes - Viewed (0)