Fluentd Log Driver: Add partial flag into record
Signed-off-by: Hiroshi Hatake <hatake@clear-code.com> Upstream-commit: 3ed3b33e558490db088103404e03539f5a3df832 Component: engine
This commit is contained in:
@ -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)
|
||||
|
||||
Reference in New Issue
Block a user