FIX logic better

Signed-off-by: yomek33 <[email protected]>
prometheus-community · Aug 2, 2024 · e4a5e41 · e4a5e41
1 parent 045bfd5
commit e4a5e41
Showing 1 changed file with 1 addition and 4 deletions.
diff --git a/metrics/serve.go b/metrics/serve.go
@@ -199,7 +199,6 @@ func handleGradualChangeMode(metricCount, metricLength, metricCycle, seriesCycle
 }
 
 func handleSpikeMode(metricCount, metricLength, metricCycle, seriesCycle int, labelKeys, labelValues []string, currentSeriesCount *int, spikeMultiplier float64, changeSeriesChan <-chan time.Time, updateNotify chan struct{}) {
-	inSpike := false
 	initialSeriesCount := *currentSeriesCount
 	for tick := range changeSeriesChan {
 		metricsMux.Lock()
@@ -208,11 +207,9 @@ func handleSpikeMode(metricCount, metricLength, metricCycle, seriesCycle int, la
 		cycleValues(labelKeys, labelValues, *currentSeriesCount, seriesCycle)
 		metricsMux.Unlock()
 
-		if inSpike {
-			inSpike = false
+		if *currentSeriesCount > initialSeriesCount {
 			*currentSeriesCount = initialSeriesCount
 		} else {
-			inSpike = true
 			*currentSeriesCount = int(float64(initialSeriesCount) * spikeMultiplier)
 		}