@@ -176,20 +176,20 @@ func handleDoubleHalveMode(metricCount, metricLength, metricCycle, seriesCycle i
176
176
}
177
177
}
178
178
179
- func handleGradualChangeMode (metricCount , metricLength , metricCycle , seriesCycle int , labelKeys , labelValues []string , seriesChangeRate , maxSeriesCount , minSeriesCount int , changeSeriesTick * time.Ticker , updateNotify chan struct {}) {
180
- currentSeriesCount := & minSeriesCount
179
+ func handleGradualChangeMode (metricCount , metricLength , metricCycle , seriesCycle int , labelKeys , labelValues []string , seriesChangeRate , maxSeriesCount , minSeriesCount int , seriesCount * int , changeSeriesTick * time.Ticker , updateNotify chan struct {}) {
180
+ * seriesCount = minSeriesCount
181
181
seriesIncrease := true
182
182
183
183
for tick := range changeSeriesTick .C {
184
184
metricsMux .Lock ()
185
185
unregisterMetrics ()
186
186
registerMetrics (metricCount , metricLength , metricCycle , labelKeys )
187
- cycleValues (labelKeys , labelValues , * currentSeriesCount , seriesCycle )
187
+ cycleValues (labelKeys , labelValues , * seriesCount , seriesCycle )
188
188
metricsMux .Unlock ()
189
189
190
- changeSeriesGradual (& seriesChangeRate , & maxSeriesCount , & minSeriesCount , currentSeriesCount , & seriesIncrease )
190
+ changeSeriesGradual (& seriesChangeRate , & maxSeriesCount , & minSeriesCount , seriesCount , & seriesIncrease )
191
191
192
- fmt .Printf ("%v: Adjusting series count. New count: %d\n " , tick , * currentSeriesCount )
192
+ fmt .Printf ("%v: Adjusting series count. New count: %d\n " , tick , * seriesCount )
193
193
194
194
select {
195
195
case updateNotify <- struct {}{}:
@@ -241,7 +241,7 @@ func RunMetrics(metricCount, labelCount, seriesCount, seriesChangeRate, maxSerie
241
241
}
242
242
registerMetrics (metricCount , metricLength , metricCycle , labelKeys )
243
243
cycleValues (labelKeys , labelValues , minSeriesCount , seriesCycle )
244
- go handleGradualChangeMode (metricCount , metricLength , metricCycle , seriesCycle , labelKeys , labelValues , seriesChangeRate , maxSeriesCount , minSeriesCount , changeSeriesTick , updateNotify )
244
+ go handleGradualChangeMode (metricCount , metricLength , metricCycle , seriesCycle , labelKeys , labelValues , seriesChangeRate , maxSeriesCount , minSeriesCount , & currentSeriesCount , changeSeriesTick , updateNotify )
245
245
go handleValueTicks (& labelKeys , & labelValues , & currentSeriesCount , & seriesCycle , updateNotify , valueTick )
246
246
go handleSeriesTicks (& labelKeys , & labelValues , & currentSeriesCount , & seriesCycle , updateNotify , seriesTick )
247
247
0 commit comments