Replace ticker with timer

moira-alert · Feb 18, 2019 · c9102f7 · c9102f7
1 parent 887c351
commit c9102f7
Showing 1 changed file with 4 additions and 7 deletions.
diff --git a/filter/matched_metrics/metrics.go b/filter/matched_metrics/metrics.go
@@ -51,13 +51,10 @@ func (matcher *MetricsMatcher) receiveBatch(metrics <-chan *moira.MatchedMetric)
 
 	go func() {
 		defer close(batchedMetrics)
-
-		batchTicker := time.NewTicker(time.Second)
-		defer batchTicker.Stop()
-
+		batchTimer := time.NewTimer(time.Second)
+		defer batchTimer.Stop()
 		for {
 			batch := make(map[string]*moira.MatchedMetric)
-
 		retry:
 			select {
 			case metric, ok := <-metrics:
@@ -71,12 +68,12 @@ func (matcher *MetricsMatcher) receiveBatch(metrics <-chan *moira.MatchedMetric)
 					goto retry
 				}
 				batchedMetrics <- batch
-			case <-batchTicker.C:
+			case <-batchTimer.C:
 				batchedMetrics <- batch
 			}
+			batchTimer.Reset(time.Second)
 		}
 	}()
-
 	return batchedMetrics
 }