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

Struct v2MessageSetBuilder

builder_test.go:165–168  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

163}
164
165type v2MessageSetBuilder struct {
166 msgs []Message
167 codec CompressionCodec
168}
169
170func (f v2MessageSetBuilder) messages() []Message {
171 return f.msgs

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected