FIX logic better

prometheus-community · Aug 2, 2024 · eaed89f · eaed89f
1 parent 045bfd5
commit eaed89f
Showing 1 changed file with 2 additions and 5 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,14 +207,12 @@ 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)
 		}
-
+		
 		fmt.Printf("%v: Adjusting series count. New count: %d\n", tick, *currentSeriesCount)
 
 		select {