MCPcopy
hub / github.com/IBM/sarama / decodeSet

Method decodeSet

message.go:186–190  ·  view source on GitHub ↗

decodes a message set from a previously encoded bulk-message

()

Source from the content-addressed store, hash-verified

184
185// decodes a message set from a previously encoded bulk-message
186func (m *Message) decodeSet() (err error) {
187 pd := realDecoder{raw: m.Value}
188 m.Set = &MessageSet{}
189 return m.Set.decode(&pd)
190}

Callers 2

decodeMethod · 0.95

Calls 1

decodeMethod · 0.65

Tested by 1