debug logging

Author: rogeralsing

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 {

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{

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)
 			}
 		}
 	})