actor counter

asynkron · Apr 6, 2024 · 8c90bda · 8c90bda
1 parent c273f8b
commit 8c90bda
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/cluster/gossiper.go b/cluster/gossiper.go
@@ -240,13 +240,20 @@ breakLoop:
 
 			g.SetState(HearthbeatKey, &MemberHeartbeat{
 				// todo collect the actor statistics
-				ActorStatistics: &ActorStatistics{},
+				ActorStatistics: &ActorStatistics{
+					ActorCount: GetActorCount(),
+				},
 			})
 			g.SendState()
 		}
 	}
 }
 
+func GetActorCount() map[string]int64 {
+	m := make(map[string]int64)
+	return m
+}
+
 // blockExpiredHeartbeats blocks members that have not sent a heartbeat for a long time
 func (g *Gossiper) blockExpiredHeartbeats() {
 	if g.cluster.Config.GossipInterval == 0 {