gossip logging (#2089)

asynkron · Jan 24, 2024 · 6f48acd · 6f48acd
1 parent 36797fa
commit 6f48acd
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 0 deletions.
diff --git a/src/Proto.Cluster/ClusterConfig.cs b/src/Proto.Cluster/ClusterConfig.cs
@@ -328,6 +328,12 @@ public ClusterConfig WithClusterContextProducer(Func<Cluster, IClusterContext> p
     /// <returns></returns>
     public ClusterConfig WithGossipRequestTimeout(TimeSpan timeout) => this with { GossipRequestTimeout = timeout };
 
+    /// <summary>
+    ///     Enables debug logging for the gossip protocol.
+    /// </summary>
+    /// <param name="enabled"></param>
+    /// <returns></returns>
+    public ClusterConfig WithGossipDebugLogging(bool enabled = true) => this with { GossipDebugLogging = enabled };
     /// <summary>
     ///     TTL for remote PID cache. Default is 15min. Set to <see cref="TimeSpan.Zero" /> to disable.
     /// </summary>

diff --git a/src/Proto.Cluster/Gossip/GossipActor.cs b/src/Proto.Cluster/Gossip/GossipActor.cs
@@ -134,6 +134,11 @@ private Task OnGossipRequest(IContext context, GossipRequest gossipRequest)
 
         ReceiveState(context, gossipRequest.State);
 
+
+        if (context.Cluster().Config.GossipDebugLogging)
+        {
+            Logger.LogInformation("Responding to GossipRequest {Request} to {MemberId}", gossipRequest, gossipRequest.MemberId);
+        }
         context.Respond(new GossipResponse());