Skip to content

Commit 8c90bda

Browse files
committed
actor counter
1 parent c273f8b commit 8c90bda

File tree

1 file changed

+8
-1
lines changed

1 file changed

+8
-1
lines changed

cluster/gossiper.go

+8-1
Original file line numberDiff line numberDiff line change
@@ -240,13 +240,20 @@ breakLoop:
240240

241241
g.SetState(HearthbeatKey, &MemberHeartbeat{
242242
// todo collect the actor statistics
243-
ActorStatistics: &ActorStatistics{},
243+
ActorStatistics: &ActorStatistics{
244+
ActorCount: GetActorCount(),
245+
},
244246
})
245247
g.SendState()
246248
}
247249
}
248250
}
249251

252+
func GetActorCount() map[string]int64 {
253+
m := make(map[string]int64)
254+
return m
255+
}
256+
250257
// blockExpiredHeartbeats blocks members that have not sent a heartbeat for a long time
251258
func (g *Gossiper) blockExpiredHeartbeats() {
252259
if g.cluster.Config.GossipInterval == 0 {

0 commit comments

Comments
 (0)