From b84e0e4a9cf2533a2588201e2aa11fdef2b2da2a Mon Sep 17 00:00:00 2001 From: evilolipop Date: Sat, 30 Dec 2023 11:28:37 +0800 Subject: [PATCH] fix: throttle debug log --- cluster/gossiper.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/cluster/gossiper.go b/cluster/gossiper.go index d45f24d1..9aa02a31 100644 --- 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