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

Function NewRecordReader

record.go:40–42  ·  view source on GitHub ↗

NewRecordReader reconstructs a RecordSet which exposes the sequence of records passed as arguments.

(records ...Record)

Source from the content-addressed store, hash-verified

38// NewRecordReader reconstructs a RecordSet which exposes the sequence of records
39// passed as arguments.
40func NewRecordReader(records ...Record) RecordReader {
41 return protocol.NewRecordReader(records...)
42}

Callers 15

TestClientDeleteOffsetFunction · 0.70
TestClientRawProduceFunction · 0.70
TestClientFetchFunction · 0.70
TestClientPipelineFunction · 0.70
TestClientOffsetCommitFunction · 0.70
FetchMethod · 0.70
TestClientProduceFunction · 0.70

Calls 1

NewRecordReaderFunction · 0.92

Tested by 14

TestClientDeleteOffsetFunction · 0.56
TestClientRawProduceFunction · 0.56
TestClientFetchFunction · 0.56
TestClientPipelineFunction · 0.56
TestClientOffsetCommitFunction · 0.56
TestClientProduceFunction · 0.56