fix: memory leak related to k8s event broadcaster in lb watcher packa…

…ge (#61) Co-authored-by: Artashes Balabekyan <[email protected]>
netrisai · Mar 3, 2022 · 0c9ad45 · 0c9ad45
1 parent 820a9e8
commit 0c9ad45
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/lbwatcher/lb_watcher.go b/lbwatcher/lb_watcher.go
@@ -65,7 +65,8 @@ func (w *Watcher) start() {
 		logger.Error(err, "")
 	}
 	cl := w.MGR.GetClient()
-	recorder, wtch, _ := eventRecorder(clientset)
+	recorder, wtch, broadcaster := eventRecorder(clientset)
+	defer broadcaster.Shutdown()
 	defer wtch.Stop()
 	w.loadBalancerProcess(clientset, cl, recorder)
 }