github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2026-07-18 13:57:38 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #133338 from aojea/service_cidr_shutdown

Browse Source 
defaultservicecidr controller no shutdown eventbroadcaster on start
This commit is contained in:
Kubernetes Prow Robot
2025-08-27 17:17:42 -07:00
committed by GitHub
parent 817534d781 81e680e6d9
commit 52f45c822f
1 changed files with 5 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
pkg/controlplane/controller/defaultservicecidr/default_servicecidr_controller.go
View File

@@ -106,10 +106,13 @@ func (c *Controller) Start(ctx context.Context) {
c.eventRecorder = c.eventBroadcaster.NewRecorder(scheme.Scheme, v1.EventSource{Component: controllerName})
c.eventBroadcaster.StartStructuredLogging(0)
c.eventBroadcaster.StartRecordingToSink(&v1core.EventSinkImpl{Interface: c.client.CoreV1().Events("")})
defer c.eventBroadcaster.Shutdown()
klog.Infof("Starting %s", controllerName)
defer klog.Infof("Shutting down %s", controllerName)
go func() {
<-ctx.Done()
klog.Infof("Shutting down %s", controllerName)
c.eventBroadcaster.Shutdown()
}()
go c.serviceCIDRInformer.Run(stopCh)
if !cache.WaitForNamedCacheSync(controllerName, stopCh, c.serviceCIDRsSynced) {