diff --git a/cluster/gossip_actor.go b/cluster/gossip_actor.go index 34e4e49d..2c4658b6 100644 --- a/cluster/gossip_actor.go +++ b/cluster/gossip_actor.go @@ -144,6 +144,7 @@ func (ga *GossipActor) onGossipRequest(r *GossipRequest, ctx actor.Context) { func (ga *GossipActor) onSetGossipStateKey(r *SetGossipStateKey, ctx actor.Context) { key, message := r.Key, r.Value + ctx.Logger().Debug("Setting GossipState", slog.String("key", key), slog.Any("message", message)) ga.gossip.SetState(key, message) if ctx.Sender() != nil { diff --git a/cluster/gossiper.go b/cluster/gossiper.go index 829d819e..3549a364 100644 --- a/cluster/gossiper.go +++ b/cluster/gossiper.go @@ -235,7 +235,6 @@ breakLoop: 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{ diff --git a/examples/cluster-gossip/node1/main.go b/examples/cluster-gossip/node1/main.go index 88ad9d2a..1762a45a 100644 --- a/examples/cluster-gossip/node1/main.go +++ b/examples/cluster-gossip/node1/main.go @@ -50,12 +50,15 @@ func startNode() *cluster.Cluster { as := &cluster.ActorStatistics{} fmt.Printf("Member %v\n", msg.MemberID) + fmt.Printf("Sequence Number %v\n", msg.SeqNumber) if unpackErr := msg.Value.UnmarshalTo(as); unpackErr != nil { //loop over as.ActorCount map for k, v := range as.ActorCount { fmt.Printf("ActorCount %v %v\n", k, v) } + } else { + fmt.Printf("Unpack error %v\n", unpackErr) } } })