- Sort Score
- Result 10 results
- Languages All
Results 21 - 29 of 29 for StartRecordingToSink (0.32 sec)
-
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) -
pkg/controller/daemon/daemon_controller.go
func (dsc *DaemonSetsController) Run(ctx context.Context, workers int) { defer utilruntime.HandleCrash() dsc.eventBroadcaster.StartStructuredLogging(3) dsc.eventBroadcaster.StartRecordingToSink(&v1core.EventSinkImpl{Interface: dsc.kubeClient.CoreV1().Events("")}) defer dsc.eventBroadcaster.Shutdown() defer dsc.queue.ShutDown() logger := klog.FromContext(ctx)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 51.3K bytes - Viewed (0) -
pkg/controller/nodelifecycle/node_lifecycle_controller.go
defer utilruntime.HandleCrash() // Start events processing pipeline. nc.broadcaster.StartStructuredLogging(3) logger := klog.FromContext(ctx) logger.Info("Sending events to api server") nc.broadcaster.StartRecordingToSink( &v1core.EventSinkImpl{ Interface: v1core.New(nc.kubeClient.CoreV1().RESTClient()).Events(""), }) defer nc.broadcaster.Shutdown() // Close node update queue to cleanup go routine.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 51.6K bytes - Viewed (0) -
cmd/kubelet/app/server.go
eventBroadcaster.StartStructuredLogging(3) if kubeDeps.EventClient != nil { klog.V(4).InfoS("Sending events to api server") eventBroadcaster.StartRecordingToSink(&v1core.EventSinkImpl{Interface: kubeDeps.EventClient.Events("")}) } else { klog.InfoS("No api server defined - no events will be sent to API server") } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 00:05:34 UTC 2024 - 53.9K bytes - Viewed (0) -
cmd/kube-proxy/app/server.go
logger.V(2).Info("Failed to apply OOMScore", "err", err) } } if s.Broadcaster != nil { stopCh := make(chan struct{}) s.Broadcaster.StartRecordingToSink(stopCh) } // TODO(thockin): make it possible for healthz and metrics to be on the same port. var healthzErrCh, metricsErrCh chan error if s.Config.BindAddressHardFail {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 26 13:27:41 UTC 2024 - 46.8K bytes - Viewed (0) -
pkg/controller/podautoscaler/horizontal.go
cpuInitializationPeriod, delayOfInitialReadinessStatus time.Duration, ) *HorizontalController { broadcaster := record.NewBroadcaster(record.WithContext(ctx)) broadcaster.StartStructuredLogging(3) broadcaster.StartRecordingToSink(&v1core.EventSinkImpl{Interface: evtNamespacer.Events("")}) recorder := broadcaster.NewRecorder(scheme.Scheme, v1.EventSource{Component: "horizontal-pod-autoscaler"}) hpaController := &HorizontalController{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 63.6K bytes - Viewed (0) -
pkg/controller/job/job_controller.go
defer utilruntime.HandleCrash() logger := klog.FromContext(ctx) // Start events processing pipeline. jm.broadcaster.StartStructuredLogging(3) jm.broadcaster.StartRecordingToSink(&v1core.EventSinkImpl{Interface: jm.kubeClient.CoreV1().Events("")}) defer jm.broadcaster.Shutdown() defer jm.queue.ShutDown() defer jm.orphanQueue.ShutDown() logger.Info("Starting job controller")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 10 23:56:37 UTC 2024 - 77.6K bytes - Viewed (0)