Add line length to batchSize (#108)

* Add line length to batchSize Signed-off-by: Eugen Biegler <nupagadi@posteo.de> * Reset batchSize in timer condition too Signed-off-by: Eugen Biegler <nupagadi@posteo.de>
grafana · Dec 14, 2018 · 1d87a22 · 1d87a22
1 parent 86fbdc0
commit 1d87a22
Showing 1 changed file with 3 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 {
@@ -126,6 +128,7 @@ 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{}
 			}
 		}