MCPcopy
hub / github.com/segmentio/kafka-go / message

Struct message

protocol/record_v1.go:232–235  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

230}
231
232type message struct {
233 Record Record
234 read bool
235}
236
237func (m *message) ReadRecord() (*Record, error) {
238 if m.read {

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected