Fluentd Log Driver: Add partial flag into record

Signed-off-by: Hiroshi Hatake <hatake@clear-code.com>
This commit is contained in:
Hiroshi Hatake 2018-01-30 17:56:30 +09:00
parent 40a9d5d24c
commit 3ed3b33e55

View file

@ -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)