- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 21 for StartRecordingToSink (1.76 sec)
-
pkg/controller/volume/persistentvolume/pv_controller_base.go
defer ctrl.claimQueue.ShutDown() defer ctrl.volumeQueue.ShutDown() // Start events processing pipeline. ctrl.eventBroadcaster.StartStructuredLogging(3) ctrl.eventBroadcaster.StartRecordingToSink(&v1core.EventSinkImpl{Interface: ctrl.kubeClient.CoreV1().Events("")}) defer ctrl.eventBroadcaster.Shutdown() logger := klog.FromContext(ctx) logger.Info("Starting persistent volume controller")
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/registry/core/service/ipallocator/controller/repairip.go
func (r *RepairIPAddress) RunUntil(onFirstSuccess func(), stopCh chan struct{}) { defer r.cidrQueue.ShutDown() defer r.ipQueue.ShutDown() defer r.svcQueue.ShutDown() r.broadcaster.StartRecordingToSink(stopCh) defer r.broadcaster.Shutdown() klog.Info("Starting ipallocator-repair-controller") defer klog.Info("Shutting down ipallocator-repair-controller")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 24.7K bytes - Viewed (0) -
pkg/controller/endpoint/endpoints_controller.go
func (e *Controller) Run(ctx context.Context, workers int) { defer utilruntime.HandleCrash() // Start events processing pipeline. e.eventBroadcaster.StartStructuredLogging(3) e.eventBroadcaster.StartRecordingToSink(&v1core.EventSinkImpl{Interface: e.client.CoreV1().Events("")}) defer e.eventBroadcaster.Shutdown() defer e.queue.ShutDown() logger := klog.FromContext(ctx) logger.Info("Starting endpoint controller")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 26.3K bytes - Viewed (0) -
pkg/controller/garbagecollector/garbagecollector.go
defer gc.attemptToOrphan.ShutDown() defer gc.dependencyGraphBuilder.graphChanges.ShutDown() // Start events processing pipeline. gc.eventBroadcaster.StartStructuredLogging(3) gc.eventBroadcaster.StartRecordingToSink(&v1core.EventSinkImpl{Interface: gc.kubeClient.CoreV1().Events("")}) defer gc.eventBroadcaster.Shutdown() logger := klog.FromContext(ctx) logger.Info("Starting controller", "controller", "garbagecollector")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 32.9K bytes - Viewed (0) -
pkg/controller/cronjob/cronjob_controllerv2.go
func (jm *ControllerV2) Run(ctx context.Context, workers int) { defer utilruntime.HandleCrash() // Start event processing pipeline. jm.broadcaster.StartStructuredLogging(3) jm.broadcaster.StartRecordingToSink(&corev1client.EventSinkImpl{Interface: jm.kubeClient.CoreV1().Events("")}) defer jm.broadcaster.Shutdown() defer jm.queue.ShutDown() logger := klog.FromContext(ctx)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 03:34:25 UTC 2024 - 29.2K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/attach_detach_controller.go
defer runtime.HandleCrash() defer adc.pvcQueue.ShutDown() // Start events processing pipeline. adc.broadcaster.StartStructuredLogging(3) adc.broadcaster.StartRecordingToSink(&v1core.EventSinkImpl{Interface: adc.kubeClient.CoreV1().Events("")}) defer adc.broadcaster.Shutdown() logger := klog.FromContext(ctx) logger.Info("Starting attach detach controller")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 32.6K bytes - Viewed (0) -
pkg/controller/resourceclaim/controller.go
defer logger.Info("Shutting down resource claim controller") eventBroadcaster := record.NewBroadcaster(record.WithContext(ctx)) eventBroadcaster.StartLogging(klog.Infof) eventBroadcaster.StartRecordingToSink(&v1core.EventSinkImpl{Interface: ec.kubeClient.CoreV1().Events("")}) ec.recorder = eventBroadcaster.NewRecorder(scheme.Scheme, v1.EventSource{Component: "resource_claim"}) defer eventBroadcaster.Shutdown()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 03:34:25 UTC 2024 - 37.1K bytes - Viewed (0) -
cmd/kube-controller-manager/app/controllermanager.go
// Start events processing pipeline. c.EventBroadcaster.StartStructuredLogging(0) c.EventBroadcaster.StartRecordingToSink(&v1core.EventSinkImpl{Interface: c.Client.CoreV1().Events("")}) defer c.EventBroadcaster.Shutdown() if cfgz, err := configz.New(ConfigzName); err == nil { cfgz.Set(c.ComponentConfig) } else {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 01 13:03:53 UTC 2024 - 37.5K bytes - Viewed (0) -
pkg/controller/disruption/disruption.go
defer utilruntime.HandleCrash() logger := klog.FromContext(ctx) // Start events processing pipeline. if dc.kubeClient != nil { logger.Info("Sending events to api server.") dc.broadcaster.StartRecordingToSink(&v1core.EventSinkImpl{Interface: dc.kubeClient.CoreV1().Events("")}) } else { logger.Info("No api server defined - no events will be sent to API server.") } defer dc.broadcaster.Shutdown()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 36.1K bytes - Viewed (0) -
pkg/controller/replicaset/replica_set.go
func (rsc *ReplicaSetController) Run(ctx context.Context, workers int) { defer utilruntime.HandleCrash() // Start events processing pipeline. rsc.eventBroadcaster.StartStructuredLogging(3) rsc.eventBroadcaster.StartRecordingToSink(&v1core.EventSinkImpl{Interface: rsc.kubeClient.CoreV1().Events("")}) defer rsc.eventBroadcaster.Shutdown() defer rsc.queue.ShutDown() controllerName := strings.ToLower(rsc.Kind)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 33.2K bytes - Viewed (0)