chore: coderabbit

Author: gfyrag

internal/leadership/broadcaster.go

@@ -9,7 +9,7 @@ type listener struct {
 }
 
 type Broadcaster struct {
-	mu *sync.Mutex
+	mu sync.Mutex
 	t  *Leadership
 
 	inner []listener
@@ -81,6 +81,5 @@ func (h *Broadcaster) CountListeners() int {
 func NewSignal() *Broadcaster {
 	return &Broadcaster{
 		outer: make(chan Leadership),
-		mu:    &sync.Mutex{},
 	}
 }

internal/leadership/manager_test.go

@@ -43,6 +43,13 @@ func TestLeaderShip(t *testing.T) {
 		}
 		return false
 	}, 2*time.Second, 10*time.Millisecond)
+	leaderCount := 0
+	for _, manager := range instances {
+		if manager.GetSignal().Actual().Acquired {
+			leaderCount++
+		}
+	}
+	require.Equal(t, 1, leaderCount)
 	require.GreaterOrEqual(t, selectedLeader, 0)
 
 	// ensure the provided db connection is still functionnal