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

Struct recordReader

protocol/record_batch.go:77–80  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

75}
76
77type recordReader struct {
78 records []Record
79 index int
80}
81
82func (r *recordReader) ReadRecord() (*Record, error) {
83 if i := r.index; i >= 0 && i < len(r.records) {

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected