MCPcopy Create free account
hub / github.com/IBM/sarama / encode

Method encode

message_set.go:59–67  ·  view source on GitHub ↗
(pe packetEncoder)

Source from the content-addressed store, hash-verified

57}
58
59func (ms *MessageSet) encode(pe packetEncoder) error {
60 for i := range ms.Messages {
61 err := ms.Messages[i].encode(pe)
62 if err != nil {
63 return err
64 }
65 }
66 return nil
67}
68
69func (ms *MessageSet) decode(pd packetDecoder) (err error) {
70 ms.Messages = nil

Callers

nothing calls this directly

Calls 1

encodeMethod · 0.65

Tested by

no test coverage detected