fix: throttle debug log

asynkron · Dec 30, 2023 · b84e0e4 · b84e0e4
1 parent 742c858
commit b84e0e4
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/cluster/gossiper.go b/cluster/gossiper.go
@@ -69,7 +69,9 @@ func newGossiper(cl *Cluster, opts ...Option) (*Gossiper, error) {
 }
 
 func (g *Gossiper) GetState(key string) (map[string]*GossipKeyValue, error) {
-	g.cluster.Logger().Debug(fmt.Sprintf("Gossiper getting state from %s", g.pid))
+	if g.throttler() == actor.Open {
+		g.cluster.Logger().Debug(fmt.Sprintf("Gossiper getting state from %s", g.pid))
+	}
 
 	msg := NewGetGossipStateRequest(key)
 	timeout := g.cluster.Config.TimeoutTime