fix: call activeWorkerrsGauge.Dec on cleanup for worker pod

ravilock · ravilock · commit 8b6f476210d7 · 2025-08-19T14:10:35.000-03:00
diff --git a/internal/manager/rpaasPodWorker.go b/internal/manager/rpaasPodWorker.go
@@ -74,8 +74,6 @@ func (w *RpaasPodWorker) Start() {
 func (w *RpaasPodWorker) Stop() {
 	if w.StopChan != nil {
 		w.StopChan <- struct{}{}
-		// Decrement active worker count
-		activeWorkersGaugeVec.WithLabelValues(w.Service, w.Instance, "pod").Dec()
 	}
 }
 
@@ -109,6 +107,7 @@ func (w *RpaasPodWorker) Work() {
 }
 
 func (w *RpaasPodWorker) cleanup() {
+	activeWorkersGaugeVec.WithLabelValues(w.Service, w.Instance, "pod").Dec()
 	close(w.ReadZoneChan)
 	close(w.WriteZoneChan)
 	close(w.StopChan)

Original file line number	Diff line number	Diff line change
`@@ -74,8 +74,6 @@ func (w *RpaasPodWorker) Start() {`
`74`	`74`	`func (w *RpaasPodWorker) Stop() {`
`75`	`75`	`if w.StopChan != nil {`
`76`	`76`	`w.StopChan <- struct{}{}`
`77`		`- // Decrement active worker count`
`78`		`- activeWorkersGaugeVec.WithLabelValues(w.Service, w.Instance, "pod").Dec()`
`79`	`77`	`}`
`80`	`78`	`}`
`81`	`79`
`@@ -109,6 +107,7 @@ func (w *RpaasPodWorker) Work() {`
`109`	`107`	`}`
`110`	`108`
`111`	`109`	`func (w *RpaasPodWorker) cleanup() {`
	`110`	`+ activeWorkersGaugeVec.WithLabelValues(w.Service, w.Instance, "pod").Dec()`
`112`	`111`	`close(w.ReadZoneChan)`
`113`	`112`	`close(w.WriteZoneChan)`
`114`	`113`	`close(w.StopChan)`