.

Author: rogeralsing

cluster/gossiper.go

@@ -174,6 +174,7 @@ func (g *Gossiper) RegisterConsensusCheck(key string, getValue func(*anypb.Any)
 
 func (g *Gossiper) StartGossiping() error {
 	var err error
+	g.cluster.Logger().Info("Starting gossip")
 	g.pid, err = g.cluster.ActorSystem.Root.SpawnNamed(actor.PropsFromProducerWithActorSystem(func(system *actor.ActorSystem) actor.Actor {
 		return NewGossipActor(
 			g.cluster.Config.GossipRequestTimeout,
@@ -221,7 +222,7 @@ func (g *Gossiper) Shutdown() {
 }
 
 func (g *Gossiper) gossipLoop() {
-	g.cluster.Logger().Info("Starting gossip loop")
+	g.cluster.Logger().Debug("Starting gossip loop")
 
 	// create a ticker that will tick each GossipInterval milliseconds
 	// we do not use sleep as sleep puts the goroutine out of the scheduler
@@ -231,26 +232,31 @@ breakLoop:
 	for !g.cluster.ActorSystem.IsStopped() {
 		select {
 		case <-g.close:
-			g.cluster.Logger().Info("Stopping Gossip Loop")
+			g.cluster.Logger().Debug("Stopping Gossip Loop")
 			break breakLoop
 		case <-ticker.C:
-
+			g.cluster.Logger().Debug("Gossip Loop Tick")
 			g.blockExpiredHeartbeats()
 			g.blockGracefullyLeft()
-
 			g.SetState(HearthbeatKey, &MemberHeartbeat{
-				// todo collect the actor statistics
 				ActorStatistics: &ActorStatistics{
-					ActorCount: GetActorCount(),
+					ActorCount: g.GetActorCount(),
 				},
 			})
 			g.SendState()
 		}
 	}
 }
 
-func GetActorCount() map[string]int64 {
+func (g *Gossiper) GetActorCount() map[string]int64 {
 	m := make(map[string]int64)
+	clusterKinds := g.cluster.GetClusterKinds()
+	for _, kindName := range clusterKinds {
+		kind := g.cluster.GetClusterKind(kindName)
+		m[kindName] = int64(kind.count)
+	}
+	g.cluster.Logger().Debug("Actor Count", slog.Any("count", m))
+
 	return m
 }
 

examples/actor-inprocess-benchmark/go.mod

@@ -2,7 +2,7 @@ module inprocessbenchmark
 
 go 1.21
 
-require github.com/asynkron/protoactor-go v0.0.0-20240116091649-93e384a26d0d
+require github.com/asynkron/protoactor-go v0.0.0-20240406090656-8c90bda12e81
 
 require (
 	github.com/Workiva/go-datastructures v1.1.1 // indirect

examples/actor-inprocess-benchmark/go.sum

@@ -2,6 +2,8 @@ github.com/Workiva/go-datastructures v1.1.1 h1:9G5u1UqKt6ABseAffHGNfbNQd7omRlWE5
 github.com/Workiva/go-datastructures v1.1.1/go.mod h1:1yZL+zfsztete+ePzZz/Zb1/t5BnDuE2Ya2MMGhzP6A=
 github.com/asynkron/protoactor-go v0.0.0-20240116091649-93e384a26d0d h1:/hjPIUib6lReKTncaTIW6FMwO/2sa2Kgv9TCDODZDpo=
 github.com/asynkron/protoactor-go v0.0.0-20240116091649-93e384a26d0d/go.mod h1:4KJf8vAca0fX3EShIBwyY77HV8NldoO1RzFGNlNkjWA=
+github.com/asynkron/protoactor-go v0.0.0-20240406090656-8c90bda12e81 h1:n/hoTcXlJ24nczsq8KwJu/hwTiuwvLZ91+WBhcWJncc=
+github.com/asynkron/protoactor-go v0.0.0-20240406090656-8c90bda12e81/go.mod h1:kFxBmdgouTsJa56gCYYZBW+0NR3RFi+g55AvxQ5ye0g=
 github.com/beorn7/perks v1.0.1 h1:VlbKKnNfV8bJzeqoa4cOKqO6bYr3WgKZxO8Z16+hsOM=
 github.com/beorn7/perks v1.0.1/go.mod h1:G2ZrVWU2WbWT9wwq4/hrbKbnv/1ERSJQ0ibhJ6rlkpw=
 github.com/cespare/xxhash/v2 v2.2.0 h1:DC2CZ1Ep5Y4k3ZQ899DldepgrayRUGE6BBZ/cd9Cj44=

examples/actor-inprocess-benchmark/inprocessbenchmark

@@ -7,7 +7,7 @@ require (
 	google.golang.org/protobuf v1.31.0
 )
 
-require github.com/asynkron/protoactor-go v0.0.0-20240116091649-93e384a26d0d
+require github.com/asynkron/protoactor-go v0.0.0-20240406090656-8c90bda12e81
 
 require (
 	github.com/Workiva/go-datastructures v1.1.1 // indirect

examples/cluster-gossip/go.mod

@@ -17,6 +17,8 @@ github.com/asynkron/gofun v0.0.0-20220329210725-34fed760f4c2 h1:jEsFZ9d/ieJGVrx3
 github.com/asynkron/gofun v0.0.0-20220329210725-34fed760f4c2/go.mod h1:5GMOSqaYxNWwuVRWyampTPJEntwz7Mj9J8v1a7gSU2E=
 github.com/asynkron/protoactor-go v0.0.0-20240116091649-93e384a26d0d h1:/hjPIUib6lReKTncaTIW6FMwO/2sa2Kgv9TCDODZDpo=
 github.com/asynkron/protoactor-go v0.0.0-20240116091649-93e384a26d0d/go.mod h1:4KJf8vAca0fX3EShIBwyY77HV8NldoO1RzFGNlNkjWA=
+github.com/asynkron/protoactor-go v0.0.0-20240406090656-8c90bda12e81 h1:n/hoTcXlJ24nczsq8KwJu/hwTiuwvLZ91+WBhcWJncc=
+github.com/asynkron/protoactor-go v0.0.0-20240406090656-8c90bda12e81/go.mod h1:kFxBmdgouTsJa56gCYYZBW+0NR3RFi+g55AvxQ5ye0g=
 github.com/beorn7/perks v0.0.0-20180321164747-3a771d992973/go.mod h1:Dwedo/Wpr24TaqPxmxbtue+5NUziq4I4S80YR8gNf3Q=
 github.com/beorn7/perks v1.0.0/go.mod h1:KWe93zE9D1o94FZ5RNwFwVgaQK1VOXiVxmqh+CedLV8=
 github.com/beorn7/perks v1.0.1 h1:VlbKKnNfV8bJzeqoa4cOKqO6bYr3WgKZxO8Z16+hsOM=

examples/cluster-gossip/go.sum

@@ -46,7 +46,12 @@ func startNode() *cluster.Cluster {
 		case *cluster.ClusterTopology:
 			fmt.Printf("\nClusterTopology %v\n\n", msg)
 		case *cluster.GossipUpdate:
-			fmt.Printf("\nGossipUpdate %v\n\n", msg)
+
+			as := &cluster.ActorStatistics{}
+
+			if unpackErr := msg.Value.UnmarshalTo(as); unpackErr != nil {
+				fmt.Printf("\nActorStatistics %v\n\n", as)
+			}
 		}
 	})