Searched defs:batchCursor (Results 1 – 3 of 3) sorted by relevance
16 type batchCursor struct { struct17 m ThreadID18 lastTs Time19 idx int // next index into []batch20 dataOff int // next index into batch.data21 ev baseEvent // last read event24 func (b *batchCursor) nextEvent(batches []batch, freq frequency) (ok bool, err error) {56 func (b *batchCursor) compare(a *batchCursor) int {102 func heapInsert(heap []*batchCursor, bc *batchCursor) []*batchCursor {111 func heapUpdate(heap []*batchCursor, i int) {[all …]
99 func heapDebugString(heap []*batchCursor) string {112 func checkHeap(t *testing.T, heap []*batchCursor) {
226 func dumpFrontier(frontier []*batchCursor) string {