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

Function makeRecords

protocol/prototest/reflect.go:112–118  ·  view source on GitHub ↗
(memoryRecords []memoryRecord)

Source from the content-addressed store, hash-verified

110}
111
112func makeRecords(memoryRecords []memoryRecord) []protocol.Record {
113 records := make([]protocol.Record, len(memoryRecords))
114 for i, m := range memoryRecords {
115 records[i] = m.Record()
116 }
117 return records
118}
119
120func loadRecords(r protocol.RecordReader) []memoryRecord {
121 records := []memoryRecord{}

Callers 1

loadValueFunction · 0.70

Calls 1

RecordMethod · 0.45

Tested by

no test coverage detected