createRecordIter creates a recordIter from a slice of *kgo.Record for testing
(records []*kgo.Record)
| 996 | |
| 997 | // createRecordIter creates a recordIter from a slice of *kgo.Record for testing |
| 998 | func createRecordIter(records []*kgo.Record) recordIter { |
| 999 | return &testRecordIter{ |
| 1000 | records: records, |
| 1001 | index: 0, |
| 1002 | } |
| 1003 | } |
| 1004 | |
| 1005 | func requireInstanceState(t *testing.T, inst *instance, state instanceState) { |
| 1006 | require.Equal(t, uint64(state.liveTraces), inst.liveTraces.Len(), "live traces count mismatch") |
no outgoing calls
no test coverage detected