From 8c90bda12e817efbe75ac42ad1ab8cf73ea29796 Mon Sep 17 00:00:00 2001 From: Roger Johansson Date: Sat, 6 Apr 2024 11:06:56 +0200 Subject: [PATCH] actor counter --- cluster/gossiper.go | 9 ++++++++- 1 file changed, 8 insertions(+), 1 deletion(-) diff --git a/cluster/gossiper.go b/cluster/gossiper.go index 40cb3e6a..ee4b0ad7 100644 --- 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 {