Add line length to batchSize

Signed-off-by: Eugen Biegler <nupagadi@posteo.de>
grafana · Dec 14, 2018 · 10da0b5 · 10da0b5
1 parent 86fbdc0
commit 10da0b5
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/pkg/promtail/client.go b/pkg/promtail/client.go
@@ -109,9 +109,11 @@ func (c *Client) run() {
 				if err := c.send(batch); err != nil {
 					level.Error(c.logger).Log("msg", "error sending batch", "error", err)
 				}
+				batchSize = 0
 				batch = map[model.Fingerprint]*logproto.Stream{}
 			}
 
+			batchSize += len(e.Line)
 			fp := e.labels.FastFingerprint()
 			stream, ok := batch[fp]
 			if !ok {