Merge pull request #59 from ikenchina/dev/metric2

fix bug : reset gauge metric if syncer is a follower
mgtv-tech · Sep 13, 2024 · 7ad2e2e · 7ad2e2e
2 parents e5ac9bb + 397da9c
commit 7ad2e2e
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/syncer/syncer.go b/syncer/syncer.go
@@ -374,6 +374,7 @@ func (s *syncer) runFollower() error {
 	s.guard.RUnlock()
 
 	s.updateStateMetric()
+	syncDelayGauge.Set(0, s.cfg.Input.Address())
 
 	s.logger.Infof("RunFollower : leader(%s)", leader.Address)