chore: coderabbit

formancehq · Jan 30, 2025 · e586965 · e586965
1 parent 0da77e0
commit e586965
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 2 deletions.
diff --git a/internal/leadership/broadcaster.go b/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{},
 	}
 }
diff --git a/internal/leadership/manager_test.go b/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