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

Method messages

builder_test.go:74–74  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

72type messageSetBuilder interface {
73 bytes() []byte
74 messages() []Message
75}
76
77type v0MessageSetBuilder struct {

Callers 2

messagesMethod · 0.65
TestMessageSetReaderFunction · 0.65

Implementers 4

fetchResponseBuilderbuilder_test.go
v0MessageSetBuilderbuilder_test.go
v1MessageSetBuilderbuilder_test.go
v2MessageSetBuilderbuilder_test.go

Calls

no outgoing calls

Tested by 2

messagesMethod · 0.52
TestMessageSetReaderFunction · 0.52