Use ticker instead of timer for batch wait

Fixes #280
grafana · Sep 5, 2019 · dca8a4f · dca8a4f
1 parent 8f9cd97
commit dca8a4f
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/pkg/promtail/client/client.go b/pkg/promtail/client/client.go
@@ -109,7 +109,7 @@ func New(cfg Config, logger log.Logger) (Client, error) {
 func (c *client) run() {
 	batch := map[model.Fingerprint]*logproto.Stream{}
 	batchSize := 0
-	maxWait := time.NewTimer(c.cfg.BatchWait)
+	maxWait := time.NewTicker(c.cfg.BatchWait)
 
 	defer func() {
 		if len(batch) > 0 {
@@ -120,7 +120,6 @@ func (c *client) run() {
 	}()
 
 	for {
-		maxWait.Reset(c.cfg.BatchWait)
 		select {
 		case <-c.quit:
 			return