xio

type BlockReader struct {
	SegmentReader
	Start     xtime.UnixNano
	BlockSize time.Duration
}

type BytesReader64 struct {
	// contains filtered or unexported fields
}

type MockSegmentReader struct {
	// contains filtered or unexported fields
}

type MockSegmentReaderMockRecorder struct {
	// contains filtered or unexported fields
}

type MockSegmentReaderPool struct {
	// contains filtered or unexported fields
}

type MockSegmentReaderPoolMockRecorder struct {
	// contains filtered or unexported fields
}

type Reader64 interface {

	// Read64 reads and returns a 64 bit word plus a number of bytes (up to 8) actually read.
	Read64() (word uint64, n byte, err error)

	// Read64 peeks and returns the next 64 bit word plus a number of bytes (up to 8) available.
	Peek64() (word uint64, n byte, err error)
}

type ReaderSliceOfSlicesFromBlockReadersIterator interface {
	ReaderSliceOfSlicesIterator

	// Reset resets the iterator with a new array of block readers arrays.
	Reset(blocks [][]BlockReader)
}

type ReaderSliceOfSlicesIterator interface {
	// Next moves to the next item.
	Next() bool

	// CurrentReaders returns the current length, start time, and block size.
	CurrentReaders() (length int, start xtime.UnixNano, blockSize time.Duration)

	// CurrentReaderAt returns the current reader in the slice
	// of readers at an index.
	CurrentReaderAt(idx int) BlockReader

	// Close closes the iterator.
	Close()

	// Size gives the size of bytes in this iterator.
	Size() (int, error)

	// RewindToIndex returns the iterator to a specific index.
	// This operation is invalid if any of the block readers have been read.
	RewindToIndex(idx int)

	// Index returns the iterator's current index.
	Index() int
}

type SegmentReader interface {
	Reader64
	xresource.Finalizer

	// Segment gets the segment read by this reader.
	Segment() (ts.Segment, error)

	// Reset resets the reader to read a new segment.
	Reset(segment ts.Segment)

	// Clone returns a clone of a copy of the underlying data reset,
	// with an optional byte pool to reduce allocations.
	Clone(pool pool.CheckedBytesPool) (SegmentReader, error)
}

type SegmentReaderPool interface {
	// Init will initialize the pool.
	Init()

	// Get provides a segment reader from the pool.
	Get() SegmentReader

	// Put returns a segment reader to the pool.
	Put(sr SegmentReader)
}