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

Function makeRecords

protocol/record_batch_test.go:29–35  ·  view source on GitHub ↗
(memoryRecords []memoryRecord)

Source from the content-addressed store, hash-verified

27}
28
29func makeRecords(memoryRecords []memoryRecord) []Record {
30 records := make([]Record, len(memoryRecords))
31 for i, m := range memoryRecords {
32 records[i] = m.Record()
33 }
34 return records
35}
36
37func TestRecordReader(t *testing.T) {
38 now := time.Now()

Callers 2

TestRecordReaderFunction · 0.70
TestMultiRecordReaderFunction · 0.70

Calls 1

RecordMethod · 0.45

Tested by

no test coverage detected