sequential marshalisation for ack.

Mathieu Lecarme · Mathieu Lecarme · commit 50ee49fb6b38 · 2022-03-02T18:05:57.000+01:00
diff --git a/message/message.go b/message/message.go
@@ -226,9 +226,9 @@ func (f *FluentReader) decodeEvent(decoder *msgpack.Decoder, encoder *msgpack.En
 			}
 		}
 		if chunk != "" {
-			err = encoder.Encode(map[string]interface{}{
-				"ack": chunk,
-			})
+			encoder.EncodeMapLen(1)
+			encoder.EncodeString("ack")
+			err = encoder.EncodeString(chunk)
 			if err != nil {
 				return err
 			}

Original file line number	Diff line number	Diff line change
`@@ -226,9 +226,9 @@ func (f FluentReader) decodeEvent(decoder msgpack.Decoder, encoder *msgpack.En`
`226`	`226`	`}`
`227`	`227`	`}`
`228`	`228`	`if chunk != "" {`
`229`		`- err = encoder.Encode(map[string]interface{}{`
`230`		`- "ack": chunk,`
`231`		`- })`
	`229`	`+ encoder.EncodeMapLen(1)`
	`230`	`+ encoder.EncodeString("ack")`
	`231`	`+ err = encoder.EncodeString(chunk)`
`232`	`232`	`if err != nil {`
`233`	`233`	`return err`
`234`	`234`	`}`