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

Function NewRawRecordSet

rawproduce_test.go:115–123  ·  view source on GitHub ↗
(reader protocol.RecordReader, attr protocol.Attributes)

Source from the content-addressed store, hash-verified

113}
114
115func NewRawRecordSet(reader protocol.RecordReader, attr protocol.Attributes) protocol.RawRecordSet {
116 rs := protocol.RecordSet{Version: 2, Attributes: attr, Records: reader}
117 buf := &bytes.Buffer{}
118 rs.WriteTo(buf)
119
120 return protocol.RawRecordSet{
121 Reader: buf,
122 }
123}

Callers 2

TestClientRawProduceFunction · 0.70

Calls 1

WriteToMethod · 0.95

Tested by

no test coverage detected