From 722d77e4b76af2b61d8040b3defd52b4d611e032 Mon Sep 17 00:00:00 2001 From: Alexei Margasov Date: Tue, 9 Apr 2019 16:11:06 +0500 Subject: [PATCH] Adds PartialLogMetadata to encode protobuf for logger plugins Signed-off-by: Alexei Margasov (cherry picked from commit 4a9836a20b35968eb931dd53a6e00b81990d8b3f) Signed-off-by: Sebastiaan van Stijn --- daemon/logger/adapter.go | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/daemon/logger/adapter.go b/daemon/logger/adapter.go index d9370352c5..97d59be5e0 100644 --- a/daemon/logger/adapter.go +++ b/daemon/logger/adapter.go @@ -39,6 +39,13 @@ func (a *pluginAdapter) Log(msg *Message) error { a.buf.TimeNano = msg.Timestamp.UnixNano() a.buf.Partial = msg.PLogMetaData != nil a.buf.Source = msg.Source + if msg.PLogMetaData != nil { + a.buf.PartialLogMetadata = &logdriver.PartialLogEntryMetadata{ + Id: msg.PLogMetaData.ID, + Last: msg.PLogMetaData.Last, + Ordinal: int32(msg.PLogMetaData.Ordinal), + } + } err := a.enc.Encode(&a.buf) a.buf.Reset()