From 0f6bd1573f2170bfe6907fa46315d521df30b04c Mon Sep 17 00:00:00 2001 From: Hiroshi Hatake Date: Tue, 30 Jan 2018 17:56:30 +0900 Subject: [PATCH] Fluentd Log Driver: Add partial flag into record Signed-off-by: Hiroshi Hatake Upstream-commit: 3ed3b33e558490db088103404e03539f5a3df832 Component: engine --- components/engine/daemon/logger/fluentd/fluentd.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/components/engine/daemon/logger/fluentd/fluentd.go b/components/engine/daemon/logger/fluentd/fluentd.go index cde36d434a..94dac7ac93 100644 --- a/components/engine/daemon/logger/fluentd/fluentd.go +++ b/components/engine/daemon/logger/fluentd/fluentd.go @@ -163,6 +163,9 @@ func (f *fluentd) Log(msg *logger.Message) error { for k, v := range f.extra { data[k] = v } + if msg.Partial { + data["partial_message"] = "true" + } ts := msg.Timestamp logger.PutMessage(msg)