From 497cff7970df86643a0df10f120694acf9848aab Mon Sep 17 00:00:00 2001
From: Cyril Tovena <cyril.tovena@gmail.com>
Date: Thu, 5 Sep 2019 11:01:44 -0400
Subject: [PATCH] Add stream label to docker driver
---
cmd/docker-driver/loki.go | 6 +++++-
1 file changed, 5 insertions(+), 1 deletion(-)
diff --git a/cmd/docker-driver/loki.go b/cmd/docker-driver/loki.go
index e8d99cea..adf8e7fe 100644
--- a/cmd/docker-driver/loki.go
+++ b/cmd/docker-driver/loki.go
@@ -55,7 +55,11 @@ func (l *loki) Log(m *logger.Message) error {
level.Info(l.logger).Log("msg", "ignoring empty line", "line", string(m.Line))
return nil
}
- return l.handler.Handle(l.labels.Clone(), m.Timestamp, string(m.Line))
+ lbs := l.labels.Clone()
+ if m.Source != "" {
+ lbs["source"] = model.LabelValue(m.Source)
+ }
+ return l.handler.Handle(lbs, m.Timestamp, string(m.Line))
}
// Log implements `logger.Logger`
--
GitLab