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

Struct v1MessageSetBuilder

builder_test.go:118–121  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

116}
117
118type v1MessageSetBuilder struct {
119 msgs []Message
120 codec CompressionCodec
121}
122
123func (f v1MessageSetBuilder) messages() []Message {
124 return f.msgs

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected