Merge pull request asynkron#1009 from qazwsxedckll/fix-throttle-log

fix: throttle debug log
kokizzu · Dec 30, 2023 · 1fcdf9e · 1fcdf9e
2 parents 742c858 + b84e0e4
commit 1fcdf9e
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