GitList

Browse code

Fluentd Log Driver: Add partial flag into record

Sebastiaan van Stijn authored on 2018/05/10 04:01:05
Showing 1 changed files

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