Adds PartialLogMetadata to encode protobuf for logger plugins

Signed-off-by: Alexei Margasov <alexei38@yandex.ru>
(cherry picked from commit 4a9836a20b35968eb931dd53a6e00b81990d8b3f)
Signed-off-by: Sebastiaan van Stijn <github@gone.nl>
Upstream-commit: 722d77e4b76af2b61d8040b3defd52b4d611e032
Component: engine
This commit is contained in:
Alexei Margasov
2019-04-09 16:11:06 +05:00
committed by Sebastiaan van Stijn
parent 52cc9db4e0
commit 2d86442852

View File

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