Add stream label to docker driver

grafana · Sep 5, 2019 · 497cff7 · 497cff7
1 parent 6b51805
commit 497cff7
Showing 1 changed file with 5 additions and 1 deletion.
diff --git 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`