Merge pull request #29 from go-graphite/rebalance/use-mps-when-reset

rebalance: use -metrics-per-second when resetting sync speed with health check
go-graphite · Nov 11, 2021 · 1a745bd · 1a745bd
2 parents 9f5b3dc + 1c1ec56
commit 1a745bd
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/buckytools.go b/buckytools.go
@@ -2,7 +2,7 @@ package buckytools
 
 const (
 	// Buckytools suite version
-	Version = "0.4.2"
+	Version = "0.5.2"
 )
 
 // SupportedHashTypes is the string identifiers of the hashing algorithms

diff --git a/cmd/bucky/common_sync.go b/cmd/bucky/common_sync.go
@@ -492,11 +492,11 @@ func (ms *metricSyncer) newGoCarbonState(addr string, speedUpInterval int) *goCa
 		for {
 			select {
 			case <-state.fastReset:
-				atomic.StoreInt64(&state.metricsPerSecond, 1)
+				atomic.StoreInt64(&state.metricsPerSecond, mps)
 				speed.Reset(time.Second / time.Duration(state.metricsPerSecond))
 			case <-speedUp.C:
 				if ms.isGoCarbonOverload(state) { // overload check
-					atomic.StoreInt64(&state.metricsPerSecond, 1)
+					atomic.StoreInt64(&state.metricsPerSecond, mps)
 				} else if !ms.flags.noRandomEasing &&
 					atomic.LoadInt64(&state.metricsPerSecond) >= 30 &&
 					rand.Intn(10) <= 2 { // random easing