encoding

package
v1.2.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 10, 2021 License: Apache-2.0 Imports: 21 Imported by: 46

Documentation

Overview

Package encoding is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func LeadingAndTrailingZeros 

func LeadingAndTrailingZeros(v uint64) (int, int)

LeadingAndTrailingZeros calculates the number of leading and trailing 0s for a uint64.

func NumSig 

func NumSig(v uint64) uint8

NumSig returns the number of significant bits in a uint64.

func SignExtend 

func SignExtend(v uint64, numBits uint8) int64

SignExtend sign extends the highest bit of v which has numBits (<=64).

func WriteSpecialMarker 

func WriteSpecialMarker(os OStream, scheme *MarkerEncodingScheme, marker Marker)

WriteSpecialMarker writes the marker that marks the start of a special symbol, e.g., the eos marker, the annotation marker, or the time unit marker.

Types

type Bit 

type Bit byte

Bit is just a byte.

type Decoder 

type Decoder interface {
	// Decode decodes the encoded data in the reader.
	Decode(reader xio.Reader64) ReaderIterator
}

Decoder is the generic interface for different types of decoders.

type Encoder 

type Encoder interface {
	// SetSchema sets up the schema needed by schema-aware encoder to encode the stream.
	// SetSchema can be called multiple times between reset for mid-stream schema changes.
	SetSchema(descr namespace.SchemaDescr)

	// Encode encodes a datapoint and optionally an annotation.
	// Schema must be set prior to Encode for schema-aware encoder. A schema can be set
	// via Reset/DiscardReset/SetSchema.
	Encode(dp ts.Datapoint, unit xtime.Unit, annotation ts.Annotation) error

	// Stream is the streaming interface for reading encoded bytes in the encoder.
	// A boolean is returned indicating whether the returned xio.SegmentReader contains
	// any data (true) or is empty (false) to encourage callers to remember to handle
	// the special case where there is an empty stream.
	// NB(r): The underlying byte slice will not be returned to the pool until the context
	// passed to this method is closed, so to avoid not returning the
	// encoder's buffer back to the pool when it is completed be sure to call
	// close on the context eventually.
	Stream(ctx xcontext.Context) (xio.SegmentReader, bool)

	// NumEncoded returns the number of encoded datapoints.
	NumEncoded() int

	// LastEncoded returns the last encoded datapoint, useful for
	// de-duplicating encoded values. If there are no previously encoded values
	// an error is returned.
	LastEncoded() (ts.Datapoint, error)

	// LastAnnotationChecksum returns the checksum of the last annotation, useful for
	// de-duplicating encoded values. If there are no previously encoded values
	// an error is returned.
	LastAnnotationChecksum() (uint64, error)

	// Len returns the length of the encoded stream as returned by a call to Stream().
	Len() int

	// Reset resets the start time of the encoder and the internal state.
	// Reset sets up the schema for schema-aware encoders such as proto encoders.
	Reset(t xtime.UnixNano, capacity int, schema namespace.SchemaDescr)

	// Close closes the encoder and if pooled will return it to the pool.
	Close()

	// Discard will take ownership of the encoder data and if pooled will return the encoder to the pool.
	Discard() ts.Segment

	// DiscardReset will take ownership of the encoder data and reset the encoder for reuse.
	// DiscardReset sets up the schema for schema-aware encoders such as proto encoders.
	DiscardReset(t xtime.UnixNano, capacity int, schema namespace.SchemaDescr) ts.Segment
}

Encoder is the generic interface for different types of encoders.

func NewNullEncoder 

func NewNullEncoder() Encoder

NewNullEncoder returns a new encoder that performs no operations

type EncoderAllocate 

type EncoderAllocate func() Encoder

EncoderAllocate allocates an encoder for a pool.

type EncoderPool 

type EncoderPool interface {
	// Init initializes the pool.
	Init(alloc EncoderAllocate)

	// Get provides an encoder from the pool.
	Get() Encoder

	// Put returns an encoder to the pool.
	Put(e Encoder)
}

EncoderPool provides a pool for encoders.

func NewEncoderPool 

func NewEncoderPool(opts pool.ObjectPoolOptions) EncoderPool

NewEncoderPool creates a new pool

type IStream 

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

IStream encapsulates a readable stream.

func NewIStream 

func NewIStream(reader64 xio.Reader64) *IStream

NewIStream creates a new IStream

func (*IStream) PeekBits 

func (is *IStream) PeekBits(numBits uint8) (uint64, error)

PeekBits looks at the next Bits, but doesn't move the pos.

func (*IStream) Read added in v0.8.2 

func (is *IStream) Read(b []byte) (int, error)

Read reads len(b) bytes.

func (*IStream) ReadBit 

func (is *IStream) ReadBit() (Bit, error)

ReadBit reads the next Bit.

func (*IStream) ReadBits 

func (is *IStream) ReadBits(numBits uint8) (uint64, error)

ReadBits reads the next Bits.

func (*IStream) ReadByte 

func (is *IStream) ReadByte() (byte, error)

ReadByte reads the next Byte.

func (*IStream) RemainingBitsInCurrentByte added in v0.8.2 

func (is *IStream) RemainingBitsInCurrentByte() uint

RemainingBitsInCurrentByte returns the number of bits remaining to be read in the current byte.

func (*IStream) Reset 

func (is *IStream) Reset(reader xio.Reader64)

Reset resets the IStream.

type IterateEqualTimestampStrategy added in v0.4.4 

type IterateEqualTimestampStrategy uint8

IterateEqualTimestampStrategy describes the strategy of which value to select when values with equal timestamps appear in the list of iterators. 

const (
	// IterateLastPushed is useful for within a single replica, using the last
	// immutable buffer that was created to decide which value to choose. It is
	// important to order the buffers passed to the construction of the iterators
	// in the correct order to achieve the desired outcome.
	IterateLastPushed IterateEqualTimestampStrategy = iota
	// IterateHighestValue is useful across replicas when you just want to choose
	// the highest value every time.
	IterateHighestValue
	// IterateLowestValue is useful across replicas when you just want to choose
	// the lowest value every time.
	IterateLowestValue
	// IterateHighestFrequencyValue is useful across replicas when you want to
	// choose the most common appearing value, however you can only use this
	// reliably if you wait for values from all replicas to be retrieved, i.e.
	// you cannot use this reliably with quorum/majority consistency.
	IterateHighestFrequencyValue

	// DefaultIterateEqualTimestampStrategy is the default iterate
	// equal timestamp strategy.
	DefaultIterateEqualTimestampStrategy = IterateLastPushed
)

func ParseIterateEqualTimestampStrategy added in v0.4.4 

func ParseIterateEqualTimestampStrategy(
	str string,
) (IterateEqualTimestampStrategy, error)

ParseIterateEqualTimestampStrategy parses a IterateEqualTimestampStrategy from a string.

func ValidIterateEqualTimestampStrategies added in v0.4.4 

func ValidIterateEqualTimestampStrategies() []IterateEqualTimestampStrategy

ValidIterateEqualTimestampStrategies returns the valid iterate equal timestamp strategies.

func (IterateEqualTimestampStrategy) String added in v0.4.4 

func (s IterateEqualTimestampStrategy) String() string

func (*IterateEqualTimestampStrategy) UnmarshalYAML added in v0.4.4 

func (s *IterateEqualTimestampStrategy) UnmarshalYAML(unmarshal func(interface{}) error) error

UnmarshalYAML unmarshals an IterateEqualTimestampStrategy into a valid type from string.

type Iterator 

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

	// Current returns the value as well as the annotation associated with the
	// current datapoint. Users should not hold on to the returned Annotation
	// object as it may get invalidated when the iterator calls Next().
	Current() (ts.Datapoint, xtime.Unit, ts.Annotation)

	// Err returns the error encountered.
	Err() error

	// Close closes the iterator and if pooled will return to the pool.
	Close()
}

Iterator is the generic interface for iterating over encoded data.

type IteratorPools 

type IteratorPools interface {
	// MultiReaderIteratorArray exposes the session MultiReaderIteratorArrayPool.
	MultiReaderIteratorArray() MultiReaderIteratorArrayPool

	// MultiReaderIterator exposes the session MultiReaderIteratorPool.
	MultiReaderIterator() MultiReaderIteratorPool

	// MutableSeriesIterators exposes the session MutableSeriesIteratorsPool.
	MutableSeriesIterators() MutableSeriesIteratorsPool

	// SeriesIterator exposes the session SeriesIteratorPool.
	SeriesIterator() SeriesIteratorPool

	// CheckedBytesWrapper exposes the session CheckedBytesWrapperPool.
	CheckedBytesWrapper() xpool.CheckedBytesWrapperPool

	// ID exposes the session identity pool.
	ID() ident.Pool

	// TagEncoder exposes the session tag encoder pool.
	TagEncoder() serialize.TagEncoderPool

	// TagDecoder exposes the session tag decoder pool.
	TagDecoder() serialize.TagDecoderPool
}

IteratorPools exposes a small subset of iterator pools that are sufficient for clients to rebuild SeriesIterator.

type Marker 

type Marker byte

Marker represents the markers.

type MarkerEncodingScheme 

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

MarkerEncodingScheme captures the information related to marker encoding.

func NewMarkerEncodingScheme added in v1.2.0 

func NewMarkerEncodingScheme(
	opcode uint64,
	numOpcodeBits int,
	numValueBits int,
	endOfStream Marker,
	annotation Marker,
	timeUnit Marker,
) *MarkerEncodingScheme

NewMarkerEncodingScheme returns new marker encoding.

func (*MarkerEncodingScheme) Annotation 

func (mes *MarkerEncodingScheme) Annotation() Marker

Annotation returns the annotation marker.

func (*MarkerEncodingScheme) EndOfStream 

func (mes *MarkerEncodingScheme) EndOfStream() Marker

EndOfStream returns the end of stream marker.

func (*MarkerEncodingScheme) NumOpcodeBits 

func (mes *MarkerEncodingScheme) NumOpcodeBits() int

NumOpcodeBits returns the number of bits used for the opcode.

func (*MarkerEncodingScheme) NumValueBits 

func (mes *MarkerEncodingScheme) NumValueBits() int

NumValueBits returns the number of bits used for the marker value.

func (*MarkerEncodingScheme) Opcode 

func (mes *MarkerEncodingScheme) Opcode() uint64

Opcode returns the marker opcode.

func (*MarkerEncodingScheme) Tail 

func (mes *MarkerEncodingScheme) Tail(b byte, pos int) checked.Bytes

Tail will return the tail portion of a stream including the relevant bits in the last byte along with the end of stream marker.

func (*MarkerEncodingScheme) TimeUnit 

func (mes *MarkerEncodingScheme) TimeUnit() Marker

TimeUnit returns the time unit marker.

type Metrics added in v1.2.0 

type Metrics struct {
	TimestampEncoder TimestampEncoderMetrics
}

Metrics contains metrics for encoding.

func NewMetrics added in v1.2.0 

func NewMetrics(scope tally.Scope) Metrics

NewMetrics returns new Metrics.

type MockDecoder 

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

MockDecoder is a mock of Decoder interface.

func NewMockDecoder 

func NewMockDecoder(ctrl *gomock.Controller) *MockDecoder

NewMockDecoder creates a new mock instance.

func (*MockDecoder) Decode 

func (m *MockDecoder) Decode(reader xio.Reader64) ReaderIterator

Decode mocks base method.

func (*MockDecoder) EXPECT 

func (m *MockDecoder) EXPECT() *MockDecoderMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

type MockDecoderMockRecorder 

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

MockDecoderMockRecorder is the mock recorder for MockDecoder.

func (*MockDecoderMockRecorder) Decode 

func (mr *MockDecoderMockRecorder) Decode(reader interface{}) *gomock.Call

Decode indicates an expected call of Decode.

type MockEncoder 

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

MockEncoder is a mock of Encoder interface.

func NewMockEncoder 

func NewMockEncoder(ctrl *gomock.Controller) *MockEncoder

NewMockEncoder creates a new mock instance.

func (*MockEncoder) Close 

func (m *MockEncoder) Close()

Close mocks base method.

func (*MockEncoder) Discard 

func (m *MockEncoder) Discard() ts.Segment

Discard mocks base method.

func (*MockEncoder) DiscardReset 

func (m *MockEncoder) DiscardReset(t time0.UnixNano, capacity int, schema namespace.SchemaDescr) ts.Segment

DiscardReset mocks base method.

func (*MockEncoder) EXPECT 

func (m *MockEncoder) EXPECT() *MockEncoderMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockEncoder) Encode 

func (m *MockEncoder) Encode(dp ts.Datapoint, unit time0.Unit, annotation ts.Annotation) error

Encode mocks base method.

func (*MockEncoder) LastAnnotationChecksum added in v1.0.0 

func (m *MockEncoder) LastAnnotationChecksum() (uint64, error)

LastAnnotationChecksum mocks base method.

func (*MockEncoder) LastEncoded added in v0.4.4 

func (m *MockEncoder) LastEncoded() (ts.Datapoint, error)

LastEncoded mocks base method.

func (*MockEncoder) Len 

func (m *MockEncoder) Len() int

Len mocks base method.

func (*MockEncoder) NumEncoded added in v0.4.4 

func (m *MockEncoder) NumEncoded() int

NumEncoded mocks base method.

func (*MockEncoder) Reset 

func (m *MockEncoder) Reset(t time0.UnixNano, capacity int, schema namespace.SchemaDescr)

Reset mocks base method.

func (*MockEncoder) SetSchema added in v0.9.2 

func (m *MockEncoder) SetSchema(descr namespace.SchemaDescr)

SetSchema mocks base method.

func (*MockEncoder) Stream 

func (m *MockEncoder) Stream(ctx context.Context) (xio.SegmentReader, bool)

Stream mocks base method.

type MockEncoderMockRecorder 

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

MockEncoderMockRecorder is the mock recorder for MockEncoder.

func (*MockEncoderMockRecorder) Close 

func (mr *MockEncoderMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockEncoderMockRecorder) Discard 

func (mr *MockEncoderMockRecorder) Discard() *gomock.Call

Discard indicates an expected call of Discard.

func (*MockEncoderMockRecorder) DiscardReset 

func (mr *MockEncoderMockRecorder) DiscardReset(t, capacity, schema interface{}) *gomock.Call

DiscardReset indicates an expected call of DiscardReset.

func (*MockEncoderMockRecorder) Encode 

func (mr *MockEncoderMockRecorder) Encode(dp, unit, annotation interface{}) *gomock.Call

Encode indicates an expected call of Encode.

func (*MockEncoderMockRecorder) LastAnnotationChecksum added in v1.0.0 

func (mr *MockEncoderMockRecorder) LastAnnotationChecksum() *gomock.Call

LastAnnotationChecksum indicates an expected call of LastAnnotationChecksum.

func (*MockEncoderMockRecorder) LastEncoded added in v0.4.4 

func (mr *MockEncoderMockRecorder) LastEncoded() *gomock.Call

LastEncoded indicates an expected call of LastEncoded.

func (*MockEncoderMockRecorder) Len 

func (mr *MockEncoderMockRecorder) Len() *gomock.Call

Len indicates an expected call of Len.

func (*MockEncoderMockRecorder) NumEncoded added in v0.4.4 

func (mr *MockEncoderMockRecorder) NumEncoded() *gomock.Call

NumEncoded indicates an expected call of NumEncoded.

func (*MockEncoderMockRecorder) Reset 

func (mr *MockEncoderMockRecorder) Reset(t, capacity, schema interface{}) *gomock.Call

Reset indicates an expected call of Reset.

func (*MockEncoderMockRecorder) SetSchema added in v0.9.2 

func (mr *MockEncoderMockRecorder) SetSchema(descr interface{}) *gomock.Call

SetSchema indicates an expected call of SetSchema.

func (*MockEncoderMockRecorder) Stream 

func (mr *MockEncoderMockRecorder) Stream(ctx interface{}) *gomock.Call

Stream indicates an expected call of Stream.

type MockEncoderPool 

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

MockEncoderPool is a mock of EncoderPool interface.

func NewMockEncoderPool 

func NewMockEncoderPool(ctrl *gomock.Controller) *MockEncoderPool

NewMockEncoderPool creates a new mock instance.

func (*MockEncoderPool) EXPECT 

func (m *MockEncoderPool) EXPECT() *MockEncoderPoolMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockEncoderPool) Get 

func (m *MockEncoderPool) Get() Encoder

Get mocks base method.

func (*MockEncoderPool) Init 

func (m *MockEncoderPool) Init(alloc EncoderAllocate)

Init mocks base method.

func (*MockEncoderPool) Put 

func (m *MockEncoderPool) Put(e Encoder)

Put mocks base method.

type MockEncoderPoolMockRecorder 

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

MockEncoderPoolMockRecorder is the mock recorder for MockEncoderPool.

func (*MockEncoderPoolMockRecorder) Get 

func (mr *MockEncoderPoolMockRecorder) Get() *gomock.Call

Get indicates an expected call of Get.

func (*MockEncoderPoolMockRecorder) Init 

func (mr *MockEncoderPoolMockRecorder) Init(alloc interface{}) *gomock.Call

Init indicates an expected call of Init.

func (*MockEncoderPoolMockRecorder) Put 

func (mr *MockEncoderPoolMockRecorder) Put(e interface{}) *gomock.Call

Put indicates an expected call of Put.

type MockIterator 

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

MockIterator is a mock of Iterator interface.

func NewMockIterator 

func NewMockIterator(ctrl *gomock.Controller) *MockIterator

NewMockIterator creates a new mock instance.

func (*MockIterator) Close 

func (m *MockIterator) Close()

Close mocks base method.

func (*MockIterator) Current 

func (m *MockIterator) Current() (ts.Datapoint, time0.Unit, ts.Annotation)

Current mocks base method.

func (*MockIterator) EXPECT 

func (m *MockIterator) EXPECT() *MockIteratorMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockIterator) Err 

func (m *MockIterator) Err() error

Err mocks base method.

func (*MockIterator) Next 

func (m *MockIterator) Next() bool

Next mocks base method.

type MockIteratorMockRecorder 

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

MockIteratorMockRecorder is the mock recorder for MockIterator.

func (*MockIteratorMockRecorder) Close 

func (mr *MockIteratorMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockIteratorMockRecorder) Current 

func (mr *MockIteratorMockRecorder) Current() *gomock.Call

Current indicates an expected call of Current.

func (*MockIteratorMockRecorder) Err 

func (mr *MockIteratorMockRecorder) Err() *gomock.Call

Err indicates an expected call of Err.

func (*MockIteratorMockRecorder) Next 

func (mr *MockIteratorMockRecorder) Next() *gomock.Call

Next indicates an expected call of Next.

type MockIteratorPools 

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

MockIteratorPools is a mock of IteratorPools interface.

func NewMockIteratorPools 

func NewMockIteratorPools(ctrl *gomock.Controller) *MockIteratorPools

NewMockIteratorPools creates a new mock instance.

func (*MockIteratorPools) CheckedBytesWrapper 

func (m *MockIteratorPools) CheckedBytesWrapper() xpool.CheckedBytesWrapperPool

CheckedBytesWrapper mocks base method.

func (*MockIteratorPools) EXPECT 

func (m *MockIteratorPools) EXPECT() *MockIteratorPoolsMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockIteratorPools) ID 

func (m *MockIteratorPools) ID() ident.Pool

ID mocks base method.

func (*MockIteratorPools) MultiReaderIterator 

func (m *MockIteratorPools) MultiReaderIterator() MultiReaderIteratorPool

MultiReaderIterator mocks base method.

func (*MockIteratorPools) MultiReaderIteratorArray 

func (m *MockIteratorPools) MultiReaderIteratorArray() MultiReaderIteratorArrayPool

MultiReaderIteratorArray mocks base method.

func (*MockIteratorPools) MutableSeriesIterators added in v0.3.0 

func (m *MockIteratorPools) MutableSeriesIterators() MutableSeriesIteratorsPool

MutableSeriesIterators mocks base method.

func (*MockIteratorPools) SeriesIterator 

func (m *MockIteratorPools) SeriesIterator() SeriesIteratorPool

SeriesIterator mocks base method.

func (*MockIteratorPools) TagDecoder added in v0.3.0 

func (m *MockIteratorPools) TagDecoder() serialize.TagDecoderPool

TagDecoder mocks base method.

func (*MockIteratorPools) TagEncoder added in v0.3.0 

func (m *MockIteratorPools) TagEncoder() serialize.TagEncoderPool

TagEncoder mocks base method.

type MockIteratorPoolsMockRecorder 

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

MockIteratorPoolsMockRecorder is the mock recorder for MockIteratorPools.

func (*MockIteratorPoolsMockRecorder) CheckedBytesWrapper 

func (mr *MockIteratorPoolsMockRecorder) CheckedBytesWrapper() *gomock.Call

CheckedBytesWrapper indicates an expected call of CheckedBytesWrapper.

func (*MockIteratorPoolsMockRecorder) ID 

func (mr *MockIteratorPoolsMockRecorder) ID() *gomock.Call

ID indicates an expected call of ID.

func (*MockIteratorPoolsMockRecorder) MultiReaderIterator 

func (mr *MockIteratorPoolsMockRecorder) MultiReaderIterator() *gomock.Call

MultiReaderIterator indicates an expected call of MultiReaderIterator.

func (*MockIteratorPoolsMockRecorder) MultiReaderIteratorArray 

func (mr *MockIteratorPoolsMockRecorder) MultiReaderIteratorArray() *gomock.Call

MultiReaderIteratorArray indicates an expected call of MultiReaderIteratorArray.

func (*MockIteratorPoolsMockRecorder) MutableSeriesIterators added in v0.3.0 

func (mr *MockIteratorPoolsMockRecorder) MutableSeriesIterators() *gomock.Call

MutableSeriesIterators indicates an expected call of MutableSeriesIterators.

func (*MockIteratorPoolsMockRecorder) SeriesIterator 

func (mr *MockIteratorPoolsMockRecorder) SeriesIterator() *gomock.Call

SeriesIterator indicates an expected call of SeriesIterator.

func (*MockIteratorPoolsMockRecorder) TagDecoder added in v0.3.0 

func (mr *MockIteratorPoolsMockRecorder) TagDecoder() *gomock.Call

TagDecoder indicates an expected call of TagDecoder.

func (*MockIteratorPoolsMockRecorder) TagEncoder added in v0.3.0 

func (mr *MockIteratorPoolsMockRecorder) TagEncoder() *gomock.Call

TagEncoder indicates an expected call of TagEncoder.

type MockMultiReaderIterator 

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

MockMultiReaderIterator is a mock of MultiReaderIterator interface.

func NewMockMultiReaderIterator 

func NewMockMultiReaderIterator(ctrl *gomock.Controller) *MockMultiReaderIterator

NewMockMultiReaderIterator creates a new mock instance.

func (*MockMultiReaderIterator) Close 

func (m *MockMultiReaderIterator) Close()

Close mocks base method.

func (*MockMultiReaderIterator) Current 

func (m *MockMultiReaderIterator) Current() (ts.Datapoint, time0.Unit, ts.Annotation)

Current mocks base method.

func (*MockMultiReaderIterator) EXPECT 

func (m *MockMultiReaderIterator) EXPECT() *MockMultiReaderIteratorMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockMultiReaderIterator) Err 

func (m *MockMultiReaderIterator) Err() error

Err mocks base method.

func (*MockMultiReaderIterator) Next 

func (m *MockMultiReaderIterator) Next() bool

Next mocks base method.

func (*MockMultiReaderIterator) Readers 

func (m *MockMultiReaderIterator) Readers() xio.ReaderSliceOfSlicesIterator

Readers mocks base method.

func (*MockMultiReaderIterator) Reset 

func (m *MockMultiReaderIterator) Reset(readers []xio.SegmentReader, start time0.UnixNano, blockSize time.Duration, schema namespace.SchemaDescr)

Reset mocks base method.

func (*MockMultiReaderIterator) ResetSliceOfSlices 

func (m *MockMultiReaderIterator) ResetSliceOfSlices(readers xio.ReaderSliceOfSlicesIterator, schema namespace.SchemaDescr)

ResetSliceOfSlices mocks base method.

func (*MockMultiReaderIterator) Schema added in v0.15.0 

func (m *MockMultiReaderIterator) Schema() namespace.SchemaDescr

Schema mocks base method.

type MockMultiReaderIteratorArrayPool 

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

MockMultiReaderIteratorArrayPool is a mock of MultiReaderIteratorArrayPool interface.

func NewMockMultiReaderIteratorArrayPool 

func NewMockMultiReaderIteratorArrayPool(ctrl *gomock.Controller) *MockMultiReaderIteratorArrayPool

NewMockMultiReaderIteratorArrayPool creates a new mock instance.

func (*MockMultiReaderIteratorArrayPool) EXPECT 

func (m *MockMultiReaderIteratorArrayPool) EXPECT() *MockMultiReaderIteratorArrayPoolMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockMultiReaderIteratorArrayPool) Get 

func (m *MockMultiReaderIteratorArrayPool) Get(size int) []MultiReaderIterator

Get mocks base method.

func (*MockMultiReaderIteratorArrayPool) Init 

func (m *MockMultiReaderIteratorArrayPool) Init()

Init mocks base method.

func (*MockMultiReaderIteratorArrayPool) Put 

func (m *MockMultiReaderIteratorArrayPool) Put(iters []MultiReaderIterator)

Put mocks base method.

type MockMultiReaderIteratorArrayPoolMockRecorder 

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

MockMultiReaderIteratorArrayPoolMockRecorder is the mock recorder for MockMultiReaderIteratorArrayPool.

func (*MockMultiReaderIteratorArrayPoolMockRecorder) Get 

func (mr *MockMultiReaderIteratorArrayPoolMockRecorder) Get(size interface{}) *gomock.Call

Get indicates an expected call of Get.

func (*MockMultiReaderIteratorArrayPoolMockRecorder) Init 

func (mr *MockMultiReaderIteratorArrayPoolMockRecorder) Init() *gomock.Call

Init indicates an expected call of Init.

func (*MockMultiReaderIteratorArrayPoolMockRecorder) Put 

func (mr *MockMultiReaderIteratorArrayPoolMockRecorder) Put(iters interface{}) *gomock.Call

Put indicates an expected call of Put.

type MockMultiReaderIteratorMockRecorder 

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

MockMultiReaderIteratorMockRecorder is the mock recorder for MockMultiReaderIterator.

func (*MockMultiReaderIteratorMockRecorder) Close 

func (mr *MockMultiReaderIteratorMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockMultiReaderIteratorMockRecorder) Current 

func (mr *MockMultiReaderIteratorMockRecorder) Current() *gomock.Call

Current indicates an expected call of Current.

func (*MockMultiReaderIteratorMockRecorder) Err 

func (mr *MockMultiReaderIteratorMockRecorder) Err() *gomock.Call

Err indicates an expected call of Err.

func (*MockMultiReaderIteratorMockRecorder) Next 

func (mr *MockMultiReaderIteratorMockRecorder) Next() *gomock.Call

Next indicates an expected call of Next.

func (*MockMultiReaderIteratorMockRecorder) Readers 

func (mr *MockMultiReaderIteratorMockRecorder) Readers() *gomock.Call

Readers indicates an expected call of Readers.

func (*MockMultiReaderIteratorMockRecorder) Reset 

func (mr *MockMultiReaderIteratorMockRecorder) Reset(readers, start, blockSize, schema interface{}) *gomock.Call

Reset indicates an expected call of Reset.

func (*MockMultiReaderIteratorMockRecorder) ResetSliceOfSlices 

func (mr *MockMultiReaderIteratorMockRecorder) ResetSliceOfSlices(readers, schema interface{}) *gomock.Call

ResetSliceOfSlices indicates an expected call of ResetSliceOfSlices.

func (*MockMultiReaderIteratorMockRecorder) Schema added in v0.15.0 

func (mr *MockMultiReaderIteratorMockRecorder) Schema() *gomock.Call

Schema indicates an expected call of Schema.

type MockMultiReaderIteratorPool 

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

MockMultiReaderIteratorPool is a mock of MultiReaderIteratorPool interface.

func NewMockMultiReaderIteratorPool 

func NewMockMultiReaderIteratorPool(ctrl *gomock.Controller) *MockMultiReaderIteratorPool

NewMockMultiReaderIteratorPool creates a new mock instance.

func (*MockMultiReaderIteratorPool) EXPECT 

func (m *MockMultiReaderIteratorPool) EXPECT() *MockMultiReaderIteratorPoolMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockMultiReaderIteratorPool) Get 

func (m *MockMultiReaderIteratorPool) Get() MultiReaderIterator

Get mocks base method.

func (*MockMultiReaderIteratorPool) Init 

func (m *MockMultiReaderIteratorPool) Init(alloc ReaderIteratorAllocate)

Init mocks base method.

func (*MockMultiReaderIteratorPool) Put 

func (m *MockMultiReaderIteratorPool) Put(iter MultiReaderIterator)

Put mocks base method.

type MockMultiReaderIteratorPoolMockRecorder 

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

MockMultiReaderIteratorPoolMockRecorder is the mock recorder for MockMultiReaderIteratorPool.

func (*MockMultiReaderIteratorPoolMockRecorder) Get 

func (mr *MockMultiReaderIteratorPoolMockRecorder) Get() *gomock.Call

Get indicates an expected call of Get.

func (*MockMultiReaderIteratorPoolMockRecorder) Init 

func (mr *MockMultiReaderIteratorPoolMockRecorder) Init(alloc interface{}) *gomock.Call

Init indicates an expected call of Init.

func (*MockMultiReaderIteratorPoolMockRecorder) Put 

func (mr *MockMultiReaderIteratorPoolMockRecorder) Put(iter interface{}) *gomock.Call

Put indicates an expected call of Put.

type MockMutableSeriesIterators 

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

MockMutableSeriesIterators is a mock of MutableSeriesIterators interface.

func NewMockMutableSeriesIterators 

func NewMockMutableSeriesIterators(ctrl *gomock.Controller) *MockMutableSeriesIterators

NewMockMutableSeriesIterators creates a new mock instance.

func (*MockMutableSeriesIterators) Cap 

func (m *MockMutableSeriesIterators) Cap() int

Cap mocks base method.

func (*MockMutableSeriesIterators) Close 

func (m *MockMutableSeriesIterators) Close()

Close mocks base method.

func (*MockMutableSeriesIterators) EXPECT 

func (m *MockMutableSeriesIterators) EXPECT() *MockMutableSeriesIteratorsMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockMutableSeriesIterators) Iters 

func (m *MockMutableSeriesIterators) Iters() []SeriesIterator

Iters mocks base method.

func (*MockMutableSeriesIterators) Len 

func (m *MockMutableSeriesIterators) Len() int

Len mocks base method.

func (*MockMutableSeriesIterators) Reset 

func (m *MockMutableSeriesIterators) Reset(size int)

Reset mocks base method.

func (*MockMutableSeriesIterators) SetAt 

func (m *MockMutableSeriesIterators) SetAt(idx int, iter SeriesIterator)

SetAt mocks base method.

type MockMutableSeriesIteratorsMockRecorder 

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

MockMutableSeriesIteratorsMockRecorder is the mock recorder for MockMutableSeriesIterators.

func (*MockMutableSeriesIteratorsMockRecorder) Cap 

func (mr *MockMutableSeriesIteratorsMockRecorder) Cap() *gomock.Call

Cap indicates an expected call of Cap.

func (*MockMutableSeriesIteratorsMockRecorder) Close 

func (mr *MockMutableSeriesIteratorsMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockMutableSeriesIteratorsMockRecorder) Iters 

func (mr *MockMutableSeriesIteratorsMockRecorder) Iters() *gomock.Call

Iters indicates an expected call of Iters.

func (*MockMutableSeriesIteratorsMockRecorder) Len 

func (mr *MockMutableSeriesIteratorsMockRecorder) Len() *gomock.Call

Len indicates an expected call of Len.

func (*MockMutableSeriesIteratorsMockRecorder) Reset 

func (mr *MockMutableSeriesIteratorsMockRecorder) Reset(size interface{}) *gomock.Call

Reset indicates an expected call of Reset.

func (*MockMutableSeriesIteratorsMockRecorder) SetAt 

func (mr *MockMutableSeriesIteratorsMockRecorder) SetAt(idx, iter interface{}) *gomock.Call

SetAt indicates an expected call of SetAt.

type MockMutableSeriesIteratorsPool 

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

MockMutableSeriesIteratorsPool is a mock of MutableSeriesIteratorsPool interface.

func NewMockMutableSeriesIteratorsPool 

func NewMockMutableSeriesIteratorsPool(ctrl *gomock.Controller) *MockMutableSeriesIteratorsPool

NewMockMutableSeriesIteratorsPool creates a new mock instance.

func (*MockMutableSeriesIteratorsPool) EXPECT 

func (m *MockMutableSeriesIteratorsPool) EXPECT() *MockMutableSeriesIteratorsPoolMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockMutableSeriesIteratorsPool) Get 

func (m *MockMutableSeriesIteratorsPool) Get(size int) MutableSeriesIterators

Get mocks base method.

func (*MockMutableSeriesIteratorsPool) Init 

func (m *MockMutableSeriesIteratorsPool) Init()

Init mocks base method.

func (*MockMutableSeriesIteratorsPool) Put 

func (m *MockMutableSeriesIteratorsPool) Put(iters MutableSeriesIterators)

Put mocks base method.

type MockMutableSeriesIteratorsPoolMockRecorder 

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

MockMutableSeriesIteratorsPoolMockRecorder is the mock recorder for MockMutableSeriesIteratorsPool.

func (*MockMutableSeriesIteratorsPoolMockRecorder) Get 

func (mr *MockMutableSeriesIteratorsPoolMockRecorder) Get(size interface{}) *gomock.Call

Get indicates an expected call of Get.

func (*MockMutableSeriesIteratorsPoolMockRecorder) Init 

func (mr *MockMutableSeriesIteratorsPoolMockRecorder) Init() *gomock.Call

Init indicates an expected call of Init.

func (*MockMutableSeriesIteratorsPoolMockRecorder) Put 

func (mr *MockMutableSeriesIteratorsPoolMockRecorder) Put(iters interface{}) *gomock.Call

Put indicates an expected call of Put.

type MockOStream 

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

MockOStream is a mock of OStream interface.

func NewMockOStream 

func NewMockOStream(ctrl *gomock.Controller) *MockOStream

NewMockOStream creates a new mock instance.

func (*MockOStream) CheckedBytes added in v0.15.0 

func (m *MockOStream) CheckedBytes() (checked.Bytes, int)

CheckedBytes mocks base method.

func (*MockOStream) Discard 

func (m *MockOStream) Discard() checked.Bytes

Discard mocks base method.

func (*MockOStream) EXPECT 

func (m *MockOStream) EXPECT() *MockOStreamMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockOStream) Empty 

func (m *MockOStream) Empty() bool

Empty mocks base method.

func (*MockOStream) Len 

func (m *MockOStream) Len() int

Len mocks base method.

func (*MockOStream) RawBytes added in v0.15.2 

func (m *MockOStream) RawBytes() ([]byte, int)

RawBytes mocks base method.

func (*MockOStream) Reset 

func (m *MockOStream) Reset(buffer checked.Bytes)

Reset mocks base method.

func (*MockOStream) Write added in v0.8.2 

func (m *MockOStream) Write(bytes []byte) (int, error)

Write mocks base method.

func (*MockOStream) WriteBit 

func (m *MockOStream) WriteBit(v Bit)

WriteBit mocks base method.

func (*MockOStream) WriteBits 

func (m *MockOStream) WriteBits(v uint64, numBits int)

WriteBits mocks base method.

func (*MockOStream) WriteByte 

func (m *MockOStream) WriteByte(v byte)

WriteByte mocks base method.

func (*MockOStream) WriteBytes 

func (m *MockOStream) WriteBytes(bytes []byte)

WriteBytes mocks base method.

type MockOStreamMockRecorder 

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

MockOStreamMockRecorder is the mock recorder for MockOStream.

func (*MockOStreamMockRecorder) CheckedBytes added in v0.15.0 

func (mr *MockOStreamMockRecorder) CheckedBytes() *gomock.Call

CheckedBytes indicates an expected call of CheckedBytes.

func (*MockOStreamMockRecorder) Discard 

func (mr *MockOStreamMockRecorder) Discard() *gomock.Call

Discard indicates an expected call of Discard.

func (*MockOStreamMockRecorder) Empty 

func (mr *MockOStreamMockRecorder) Empty() *gomock.Call

Empty indicates an expected call of Empty.

func (*MockOStreamMockRecorder) Len 

func (mr *MockOStreamMockRecorder) Len() *gomock.Call

Len indicates an expected call of Len.

func (*MockOStreamMockRecorder) RawBytes added in v0.15.2 

func (mr *MockOStreamMockRecorder) RawBytes() *gomock.Call

RawBytes indicates an expected call of RawBytes.

func (*MockOStreamMockRecorder) Reset 

func (mr *MockOStreamMockRecorder) Reset(buffer interface{}) *gomock.Call

Reset indicates an expected call of Reset.

func (*MockOStreamMockRecorder) Write added in v0.8.2 

func (mr *MockOStreamMockRecorder) Write(bytes interface{}) *gomock.Call

Write indicates an expected call of Write.

func (*MockOStreamMockRecorder) WriteBit 

func (mr *MockOStreamMockRecorder) WriteBit(v interface{}) *gomock.Call

WriteBit indicates an expected call of WriteBit.

func (*MockOStreamMockRecorder) WriteBits 

func (mr *MockOStreamMockRecorder) WriteBits(v, numBits interface{}) *gomock.Call

WriteBits indicates an expected call of WriteBits.

func (*MockOStreamMockRecorder) WriteByte 

func (mr *MockOStreamMockRecorder) WriteByte(v interface{}) *gomock.Call

WriteByte indicates an expected call of WriteByte.

func (*MockOStreamMockRecorder) WriteBytes 

func (mr *MockOStreamMockRecorder) WriteBytes(bytes interface{}) *gomock.Call

WriteBytes indicates an expected call of WriteBytes.

type MockOptions 

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

MockOptions is a mock of Options interface.

func NewMockOptions 

func NewMockOptions(ctrl *gomock.Controller) *MockOptions

NewMockOptions creates a new mock instance.

func (*MockOptions) ByteFieldDictionaryLRUSize added in v0.8.2 

func (m *MockOptions) ByteFieldDictionaryLRUSize() int

ByteFieldDictionaryLRUSize mocks base method.

func (*MockOptions) BytesPool 

func (m *MockOptions) BytesPool() pool.CheckedBytesPool

BytesPool mocks base method.

func (*MockOptions) CheckedBytesWrapperPool added in v0.15.0 

func (m *MockOptions) CheckedBytesWrapperPool() xpool.CheckedBytesWrapperPool

CheckedBytesWrapperPool mocks base method.

func (*MockOptions) DefaultTimeUnit 

func (m *MockOptions) DefaultTimeUnit() time0.Unit

DefaultTimeUnit mocks base method.

func (*MockOptions) EXPECT 

func (m *MockOptions) EXPECT() *MockOptionsMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockOptions) EncoderPool 

func (m *MockOptions) EncoderPool() EncoderPool

EncoderPool mocks base method.

func (*MockOptions) IStreamReaderSizeM3TSZ added in v0.14.1 

func (m *MockOptions) IStreamReaderSizeM3TSZ() int

IStreamReaderSizeM3TSZ mocks base method.

func (*MockOptions) IStreamReaderSizeProto added in v0.14.1 

func (m *MockOptions) IStreamReaderSizeProto() int

IStreamReaderSizeProto mocks base method.

func (*MockOptions) MarkerEncodingScheme 

func (m *MockOptions) MarkerEncodingScheme() *MarkerEncodingScheme

MarkerEncodingScheme mocks base method.

func (*MockOptions) Metrics added in v1.2.0 

func (m *MockOptions) Metrics() Metrics

Metrics mocks base method.

func (*MockOptions) ReaderIteratorPool 

func (m *MockOptions) ReaderIteratorPool() ReaderIteratorPool

ReaderIteratorPool mocks base method.

func (*MockOptions) SegmentReaderPool 

func (m *MockOptions) SegmentReaderPool() xio.SegmentReaderPool

SegmentReaderPool mocks base method.

func (*MockOptions) SetByteFieldDictionaryLRUSize added in v0.8.2 

func (m *MockOptions) SetByteFieldDictionaryLRUSize(value int) Options

SetByteFieldDictionaryLRUSize mocks base method.

func (*MockOptions) SetBytesPool 

func (m *MockOptions) SetBytesPool(value pool.CheckedBytesPool) Options

SetBytesPool mocks base method.

func (*MockOptions) SetCheckedBytesWrapperPool added in v0.15.0 

func (m *MockOptions) SetCheckedBytesWrapperPool(value xpool.CheckedBytesWrapperPool) Options

SetCheckedBytesWrapperPool mocks base method.

func (*MockOptions) SetDefaultTimeUnit 

func (m *MockOptions) SetDefaultTimeUnit(tu time0.Unit) Options

SetDefaultTimeUnit mocks base method.

func (*MockOptions) SetEncoderPool 

func (m *MockOptions) SetEncoderPool(value EncoderPool) Options

SetEncoderPool mocks base method.

func (*MockOptions) SetIStreamReaderSizeM3TSZ added in v0.14.1 

func (m *MockOptions) SetIStreamReaderSizeM3TSZ(value int) Options

SetIStreamReaderSizeM3TSZ mocks base method.

func (*MockOptions) SetIStreamReaderSizeProto added in v0.14.1 

func (m *MockOptions) SetIStreamReaderSizeProto(value int) Options

SetIStreamReaderSizeProto mocks base method.

func (*MockOptions) SetMarkerEncodingScheme 

func (m *MockOptions) SetMarkerEncodingScheme(value *MarkerEncodingScheme) Options

SetMarkerEncodingScheme mocks base method.

func (*MockOptions) SetMetrics added in v1.2.0 

func (m *MockOptions) SetMetrics(value Metrics) Options

SetMetrics mocks base method.

func (*MockOptions) SetReaderIteratorPool 

func (m *MockOptions) SetReaderIteratorPool(value ReaderIteratorPool) Options

SetReaderIteratorPool mocks base method.

func (*MockOptions) SetSegmentReaderPool 

func (m *MockOptions) SetSegmentReaderPool(value xio.SegmentReaderPool) Options

SetSegmentReaderPool mocks base method.

func (*MockOptions) SetTimeEncodingSchemes 

func (m *MockOptions) SetTimeEncodingSchemes(value map[time0.Unit]TimeEncodingScheme) Options

SetTimeEncodingSchemes mocks base method.

func (*MockOptions) TimeEncodingSchemes 

func (m *MockOptions) TimeEncodingSchemes() TimeEncodingSchemes

TimeEncodingSchemes mocks base method.

type MockOptionsMockRecorder 

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

MockOptionsMockRecorder is the mock recorder for MockOptions.

func (*MockOptionsMockRecorder) ByteFieldDictionaryLRUSize added in v0.8.2 

func (mr *MockOptionsMockRecorder) ByteFieldDictionaryLRUSize() *gomock.Call

ByteFieldDictionaryLRUSize indicates an expected call of ByteFieldDictionaryLRUSize.

func (*MockOptionsMockRecorder) BytesPool 

func (mr *MockOptionsMockRecorder) BytesPool() *gomock.Call

BytesPool indicates an expected call of BytesPool.

func (*MockOptionsMockRecorder) CheckedBytesWrapperPool added in v0.15.0 

func (mr *MockOptionsMockRecorder) CheckedBytesWrapperPool() *gomock.Call

CheckedBytesWrapperPool indicates an expected call of CheckedBytesWrapperPool.

func (*MockOptionsMockRecorder) DefaultTimeUnit 

func (mr *MockOptionsMockRecorder) DefaultTimeUnit() *gomock.Call

DefaultTimeUnit indicates an expected call of DefaultTimeUnit.

func (*MockOptionsMockRecorder) EncoderPool 

func (mr *MockOptionsMockRecorder) EncoderPool() *gomock.Call

EncoderPool indicates an expected call of EncoderPool.

func (*MockOptionsMockRecorder) IStreamReaderSizeM3TSZ added in v0.14.1 

func (mr *MockOptionsMockRecorder) IStreamReaderSizeM3TSZ() *gomock.Call

IStreamReaderSizeM3TSZ indicates an expected call of IStreamReaderSizeM3TSZ.

func (*MockOptionsMockRecorder) IStreamReaderSizeProto added in v0.14.1 

func (mr *MockOptionsMockRecorder) IStreamReaderSizeProto() *gomock.Call

IStreamReaderSizeProto indicates an expected call of IStreamReaderSizeProto.

func (*MockOptionsMockRecorder) MarkerEncodingScheme 

func (mr *MockOptionsMockRecorder) MarkerEncodingScheme() *gomock.Call

MarkerEncodingScheme indicates an expected call of MarkerEncodingScheme.

func (*MockOptionsMockRecorder) Metrics added in v1.2.0 

func (mr *MockOptionsMockRecorder) Metrics() *gomock.Call

Metrics indicates an expected call of Metrics.

func (*MockOptionsMockRecorder) ReaderIteratorPool 

func (mr *MockOptionsMockRecorder) ReaderIteratorPool() *gomock.Call

ReaderIteratorPool indicates an expected call of ReaderIteratorPool.

func (*MockOptionsMockRecorder) SegmentReaderPool 

func (mr *MockOptionsMockRecorder) SegmentReaderPool() *gomock.Call

SegmentReaderPool indicates an expected call of SegmentReaderPool.

func (*MockOptionsMockRecorder) SetByteFieldDictionaryLRUSize added in v0.8.2 

func (mr *MockOptionsMockRecorder) SetByteFieldDictionaryLRUSize(value interface{}) *gomock.Call

SetByteFieldDictionaryLRUSize indicates an expected call of SetByteFieldDictionaryLRUSize.

func (*MockOptionsMockRecorder) SetBytesPool 

func (mr *MockOptionsMockRecorder) SetBytesPool(value interface{}) *gomock.Call

SetBytesPool indicates an expected call of SetBytesPool.

func (*MockOptionsMockRecorder) SetCheckedBytesWrapperPool added in v0.15.0 

func (mr *MockOptionsMockRecorder) SetCheckedBytesWrapperPool(value interface{}) *gomock.Call

SetCheckedBytesWrapperPool indicates an expected call of SetCheckedBytesWrapperPool.

func (*MockOptionsMockRecorder) SetDefaultTimeUnit 

func (mr *MockOptionsMockRecorder) SetDefaultTimeUnit(tu interface{}) *gomock.Call

SetDefaultTimeUnit indicates an expected call of SetDefaultTimeUnit.

func (*MockOptionsMockRecorder) SetEncoderPool 

func (mr *MockOptionsMockRecorder) SetEncoderPool(value interface{}) *gomock.Call

SetEncoderPool indicates an expected call of SetEncoderPool.

func (*MockOptionsMockRecorder) SetIStreamReaderSizeM3TSZ added in v0.14.1 

func (mr *MockOptionsMockRecorder) SetIStreamReaderSizeM3TSZ(value interface{}) *gomock.Call

SetIStreamReaderSizeM3TSZ indicates an expected call of SetIStreamReaderSizeM3TSZ.

func (*MockOptionsMockRecorder) SetIStreamReaderSizeProto added in v0.14.1 

func (mr *MockOptionsMockRecorder) SetIStreamReaderSizeProto(value interface{}) *gomock.Call

SetIStreamReaderSizeProto indicates an expected call of SetIStreamReaderSizeProto.

func (*MockOptionsMockRecorder) SetMarkerEncodingScheme 

func (mr *MockOptionsMockRecorder) SetMarkerEncodingScheme(value interface{}) *gomock.Call

SetMarkerEncodingScheme indicates an expected call of SetMarkerEncodingScheme.

func (*MockOptionsMockRecorder) SetMetrics added in v1.2.0 

func (mr *MockOptionsMockRecorder) SetMetrics(value interface{}) *gomock.Call

SetMetrics indicates an expected call of SetMetrics.

func (*MockOptionsMockRecorder) SetReaderIteratorPool 

func (mr *MockOptionsMockRecorder) SetReaderIteratorPool(value interface{}) *gomock.Call

SetReaderIteratorPool indicates an expected call of SetReaderIteratorPool.

func (*MockOptionsMockRecorder) SetSegmentReaderPool 

func (mr *MockOptionsMockRecorder) SetSegmentReaderPool(value interface{}) *gomock.Call

SetSegmentReaderPool indicates an expected call of SetSegmentReaderPool.

func (*MockOptionsMockRecorder) SetTimeEncodingSchemes 

func (mr *MockOptionsMockRecorder) SetTimeEncodingSchemes(value interface{}) *gomock.Call

SetTimeEncodingSchemes indicates an expected call of SetTimeEncodingSchemes.

func (*MockOptionsMockRecorder) TimeEncodingSchemes 

func (mr *MockOptionsMockRecorder) TimeEncodingSchemes() *gomock.Call

TimeEncodingSchemes indicates an expected call of TimeEncodingSchemes.

type MockReaderIterator 

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

MockReaderIterator is a mock of ReaderIterator interface.

func NewMockReaderIterator 

func NewMockReaderIterator(ctrl *gomock.Controller) *MockReaderIterator

NewMockReaderIterator creates a new mock instance.

func (*MockReaderIterator) Close 

func (m *MockReaderIterator) Close()

Close mocks base method.

func (*MockReaderIterator) Current 

func (m *MockReaderIterator) Current() (ts.Datapoint, time0.Unit, ts.Annotation)

Current mocks base method.

func (*MockReaderIterator) EXPECT 

func (m *MockReaderIterator) EXPECT() *MockReaderIteratorMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockReaderIterator) Err 

func (m *MockReaderIterator) Err() error

Err mocks base method.

func (*MockReaderIterator) Next 

func (m *MockReaderIterator) Next() bool

Next mocks base method.

func (*MockReaderIterator) Reset 

func (m *MockReaderIterator) Reset(reader xio.Reader64, schema namespace.SchemaDescr)

Reset mocks base method.

type MockReaderIteratorMockRecorder 

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

MockReaderIteratorMockRecorder is the mock recorder for MockReaderIterator.

func (*MockReaderIteratorMockRecorder) Close 

func (mr *MockReaderIteratorMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockReaderIteratorMockRecorder) Current 

func (mr *MockReaderIteratorMockRecorder) Current() *gomock.Call

Current indicates an expected call of Current.

func (*MockReaderIteratorMockRecorder) Err 

func (mr *MockReaderIteratorMockRecorder) Err() *gomock.Call

Err indicates an expected call of Err.

func (*MockReaderIteratorMockRecorder) Next 

func (mr *MockReaderIteratorMockRecorder) Next() *gomock.Call

Next indicates an expected call of Next.

func (*MockReaderIteratorMockRecorder) Reset 

func (mr *MockReaderIteratorMockRecorder) Reset(reader, schema interface{}) *gomock.Call

Reset indicates an expected call of Reset.

type MockReaderIteratorPool 

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

MockReaderIteratorPool is a mock of ReaderIteratorPool interface.

func NewMockReaderIteratorPool 

func NewMockReaderIteratorPool(ctrl *gomock.Controller) *MockReaderIteratorPool

NewMockReaderIteratorPool creates a new mock instance.

func (*MockReaderIteratorPool) EXPECT 

func (m *MockReaderIteratorPool) EXPECT() *MockReaderIteratorPoolMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockReaderIteratorPool) Get 

func (m *MockReaderIteratorPool) Get() ReaderIterator

Get mocks base method.

func (*MockReaderIteratorPool) Init 

func (m *MockReaderIteratorPool) Init(alloc ReaderIteratorAllocate)

Init mocks base method.

func (*MockReaderIteratorPool) Put 

func (m *MockReaderIteratorPool) Put(iter ReaderIterator)

Put mocks base method.

type MockReaderIteratorPoolMockRecorder 

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

MockReaderIteratorPoolMockRecorder is the mock recorder for MockReaderIteratorPool.

func (*MockReaderIteratorPoolMockRecorder) Get 

func (mr *MockReaderIteratorPoolMockRecorder) Get() *gomock.Call

Get indicates an expected call of Get.

func (*MockReaderIteratorPoolMockRecorder) Init 

func (mr *MockReaderIteratorPoolMockRecorder) Init(alloc interface{}) *gomock.Call

Init indicates an expected call of Init.

func (*MockReaderIteratorPoolMockRecorder) Put 

func (mr *MockReaderIteratorPoolMockRecorder) Put(iter interface{}) *gomock.Call

Put indicates an expected call of Put.

type MockSeriesIterator 

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

MockSeriesIterator is a mock of SeriesIterator interface.

func NewMockSeriesIterator 

func NewMockSeriesIterator(ctrl *gomock.Controller) *MockSeriesIterator

NewMockSeriesIterator creates a new mock instance.

func (*MockSeriesIterator) Close 

func (m *MockSeriesIterator) Close()

Close mocks base method.

func (*MockSeriesIterator) Current 

func (m *MockSeriesIterator) Current() (ts.Datapoint, time0.Unit, ts.Annotation)

Current mocks base method.

func (*MockSeriesIterator) EXPECT 

func (m *MockSeriesIterator) EXPECT() *MockSeriesIteratorMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockSeriesIterator) End 

func (m *MockSeriesIterator) End() time0.UnixNano

End mocks base method.

func (*MockSeriesIterator) Err 

func (m *MockSeriesIterator) Err() error

Err mocks base method.

func (*MockSeriesIterator) ID 

func (m *MockSeriesIterator) ID() ident.ID

ID mocks base method.

func (*MockSeriesIterator) Namespace 

func (m *MockSeriesIterator) Namespace() ident.ID

Namespace mocks base method.

func (*MockSeriesIterator) Next 

func (m *MockSeriesIterator) Next() bool

Next mocks base method.

func (*MockSeriesIterator) Replicas 

func (m *MockSeriesIterator) Replicas() ([]MultiReaderIterator, error)

Replicas mocks base method.

func (*MockSeriesIterator) Reset 

func (m *MockSeriesIterator) Reset(opts SeriesIteratorOptions)

Reset mocks base method.

func (*MockSeriesIterator) SetIterateEqualTimestampStrategy added in v0.4.4 

func (m *MockSeriesIterator) SetIterateEqualTimestampStrategy(strategy IterateEqualTimestampStrategy)

SetIterateEqualTimestampStrategy mocks base method.

func (*MockSeriesIterator) Start 

func (m *MockSeriesIterator) Start() time0.UnixNano

Start mocks base method.

func (*MockSeriesIterator) Stats added in v0.15.0 

func (m *MockSeriesIterator) Stats() (SeriesIteratorStats, error)

Stats mocks base method.

func (*MockSeriesIterator) Tags 

func (m *MockSeriesIterator) Tags() ident.TagIterator

Tags mocks base method.

type MockSeriesIteratorAccumulator added in v0.15.2 

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

MockSeriesIteratorAccumulator is a mock of SeriesIteratorAccumulator interface.

func NewMockSeriesIteratorAccumulator added in v0.15.2 

func NewMockSeriesIteratorAccumulator(ctrl *gomock.Controller) *MockSeriesIteratorAccumulator

NewMockSeriesIteratorAccumulator creates a new mock instance.

func (*MockSeriesIteratorAccumulator) Add added in v0.15.2 

func (m *MockSeriesIteratorAccumulator) Add(it SeriesIterator) error

Add mocks base method.

func (*MockSeriesIteratorAccumulator) Close added in v0.15.2 

func (m *MockSeriesIteratorAccumulator) Close()

Close mocks base method.

func (*MockSeriesIteratorAccumulator) Current added in v0.15.2 

func (m *MockSeriesIteratorAccumulator) Current() (ts.Datapoint, time0.Unit, ts.Annotation)

Current mocks base method.

func (*MockSeriesIteratorAccumulator) EXPECT added in v0.15.2 

func (m *MockSeriesIteratorAccumulator) EXPECT() *MockSeriesIteratorAccumulatorMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockSeriesIteratorAccumulator) End added in v0.15.2 

func (m *MockSeriesIteratorAccumulator) End() time0.UnixNano

End mocks base method.

func (*MockSeriesIteratorAccumulator) Err added in v0.15.2 

func (m *MockSeriesIteratorAccumulator) Err() error

Err mocks base method.

func (*MockSeriesIteratorAccumulator) ID added in v0.15.2 

func (m *MockSeriesIteratorAccumulator) ID() ident.ID

ID mocks base method.

func (*MockSeriesIteratorAccumulator) Namespace added in v0.15.2 

func (m *MockSeriesIteratorAccumulator) Namespace() ident.ID

Namespace mocks base method.

func (*MockSeriesIteratorAccumulator) Next added in v0.15.2 

func (m *MockSeriesIteratorAccumulator) Next() bool

Next mocks base method.

func (*MockSeriesIteratorAccumulator) Replicas added in v0.15.2 

func (m *MockSeriesIteratorAccumulator) Replicas() ([]MultiReaderIterator, error)

Replicas mocks base method.

func (*MockSeriesIteratorAccumulator) Reset added in v0.15.2 

func (m *MockSeriesIteratorAccumulator) Reset(opts SeriesIteratorOptions)

Reset mocks base method.

func (*MockSeriesIteratorAccumulator) SetIterateEqualTimestampStrategy added in v0.15.2 

func (m *MockSeriesIteratorAccumulator) SetIterateEqualTimestampStrategy(strategy IterateEqualTimestampStrategy)

SetIterateEqualTimestampStrategy mocks base method.

func (*MockSeriesIteratorAccumulator) Start added in v0.15.2 

func (m *MockSeriesIteratorAccumulator) Start() time0.UnixNano

Start mocks base method.

func (*MockSeriesIteratorAccumulator) Stats added in v0.15.2 

func (m *MockSeriesIteratorAccumulator) Stats() (SeriesIteratorStats, error)

Stats mocks base method.

func (*MockSeriesIteratorAccumulator) Tags added in v0.15.2 

func (m *MockSeriesIteratorAccumulator) Tags() ident.TagIterator

Tags mocks base method.

type MockSeriesIteratorAccumulatorMockRecorder added in v0.15.2 

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

MockSeriesIteratorAccumulatorMockRecorder is the mock recorder for MockSeriesIteratorAccumulator.

func (*MockSeriesIteratorAccumulatorMockRecorder) Add added in v0.15.2 

func (mr *MockSeriesIteratorAccumulatorMockRecorder) Add(it interface{}) *gomock.Call

Add indicates an expected call of Add.

func (*MockSeriesIteratorAccumulatorMockRecorder) Close added in v0.15.2 

func (mr *MockSeriesIteratorAccumulatorMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockSeriesIteratorAccumulatorMockRecorder) Current added in v0.15.2 

func (mr *MockSeriesIteratorAccumulatorMockRecorder) Current() *gomock.Call

Current indicates an expected call of Current.

func (*MockSeriesIteratorAccumulatorMockRecorder) End added in v0.15.2 

func (mr *MockSeriesIteratorAccumulatorMockRecorder) End() *gomock.Call

End indicates an expected call of End.

func (*MockSeriesIteratorAccumulatorMockRecorder) Err added in v0.15.2 

func (mr *MockSeriesIteratorAccumulatorMockRecorder) Err() *gomock.Call

Err indicates an expected call of Err.

func (*MockSeriesIteratorAccumulatorMockRecorder) ID added in v0.15.2 

func (mr *MockSeriesIteratorAccumulatorMockRecorder) ID() *gomock.Call

ID indicates an expected call of ID.

func (*MockSeriesIteratorAccumulatorMockRecorder) Namespace added in v0.15.2 

func (mr *MockSeriesIteratorAccumulatorMockRecorder) Namespace() *gomock.Call

Namespace indicates an expected call of Namespace.

func (*MockSeriesIteratorAccumulatorMockRecorder) Next added in v0.15.2 

func (mr *MockSeriesIteratorAccumulatorMockRecorder) Next() *gomock.Call

Next indicates an expected call of Next.

func (*MockSeriesIteratorAccumulatorMockRecorder) Replicas added in v0.15.2 

func (mr *MockSeriesIteratorAccumulatorMockRecorder) Replicas() *gomock.Call

Replicas indicates an expected call of Replicas.

func (*MockSeriesIteratorAccumulatorMockRecorder) Reset added in v0.15.2 

func (mr *MockSeriesIteratorAccumulatorMockRecorder) Reset(opts interface{}) *gomock.Call

Reset indicates an expected call of Reset.

func (*MockSeriesIteratorAccumulatorMockRecorder) SetIterateEqualTimestampStrategy added in v0.15.2 

func (mr *MockSeriesIteratorAccumulatorMockRecorder) SetIterateEqualTimestampStrategy(strategy interface{}) *gomock.Call

SetIterateEqualTimestampStrategy indicates an expected call of SetIterateEqualTimestampStrategy.

func (*MockSeriesIteratorAccumulatorMockRecorder) Start added in v0.15.2 

func (mr *MockSeriesIteratorAccumulatorMockRecorder) Start() *gomock.Call

Start indicates an expected call of Start.

func (*MockSeriesIteratorAccumulatorMockRecorder) Stats added in v0.15.2 

func (mr *MockSeriesIteratorAccumulatorMockRecorder) Stats() *gomock.Call

Stats indicates an expected call of Stats.

func (*MockSeriesIteratorAccumulatorMockRecorder) Tags added in v0.15.2 

func (mr *MockSeriesIteratorAccumulatorMockRecorder) Tags() *gomock.Call

Tags indicates an expected call of Tags.

type MockSeriesIteratorConsolidator added in v0.15.0 

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

MockSeriesIteratorConsolidator is a mock of SeriesIteratorConsolidator interface.

func NewMockSeriesIteratorConsolidator added in v0.15.0 

func NewMockSeriesIteratorConsolidator(ctrl *gomock.Controller) *MockSeriesIteratorConsolidator

NewMockSeriesIteratorConsolidator creates a new mock instance.

func (*MockSeriesIteratorConsolidator) ConsolidateReplicas added in v0.15.0 

func (m *MockSeriesIteratorConsolidator) ConsolidateReplicas(replicas []MultiReaderIterator) ([]MultiReaderIterator, error)

ConsolidateReplicas mocks base method.

func (*MockSeriesIteratorConsolidator) EXPECT added in v0.15.0 

func (m *MockSeriesIteratorConsolidator) EXPECT() *MockSeriesIteratorConsolidatorMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

type MockSeriesIteratorConsolidatorMockRecorder added in v0.15.0 

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

MockSeriesIteratorConsolidatorMockRecorder is the mock recorder for MockSeriesIteratorConsolidator.

func (*MockSeriesIteratorConsolidatorMockRecorder) ConsolidateReplicas added in v0.15.0 

func (mr *MockSeriesIteratorConsolidatorMockRecorder) ConsolidateReplicas(replicas interface{}) *gomock.Call

ConsolidateReplicas indicates an expected call of ConsolidateReplicas.

type MockSeriesIteratorMockRecorder 

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

MockSeriesIteratorMockRecorder is the mock recorder for MockSeriesIterator.

func (*MockSeriesIteratorMockRecorder) Close 

func (mr *MockSeriesIteratorMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockSeriesIteratorMockRecorder) Current 

func (mr *MockSeriesIteratorMockRecorder) Current() *gomock.Call

Current indicates an expected call of Current.

func (*MockSeriesIteratorMockRecorder) End 

func (mr *MockSeriesIteratorMockRecorder) End() *gomock.Call

End indicates an expected call of End.

func (*MockSeriesIteratorMockRecorder) Err 

func (mr *MockSeriesIteratorMockRecorder) Err() *gomock.Call

Err indicates an expected call of Err.

func (*MockSeriesIteratorMockRecorder) ID 

func (mr *MockSeriesIteratorMockRecorder) ID() *gomock.Call

ID indicates an expected call of ID.

func (*MockSeriesIteratorMockRecorder) Namespace 

func (mr *MockSeriesIteratorMockRecorder) Namespace() *gomock.Call

Namespace indicates an expected call of Namespace.

func (*MockSeriesIteratorMockRecorder) Next 

func (mr *MockSeriesIteratorMockRecorder) Next() *gomock.Call

Next indicates an expected call of Next.

func (*MockSeriesIteratorMockRecorder) Replicas 

func (mr *MockSeriesIteratorMockRecorder) Replicas() *gomock.Call

Replicas indicates an expected call of Replicas.

func (*MockSeriesIteratorMockRecorder) Reset 

func (mr *MockSeriesIteratorMockRecorder) Reset(opts interface{}) *gomock.Call

Reset indicates an expected call of Reset.

func (*MockSeriesIteratorMockRecorder) SetIterateEqualTimestampStrategy added in v0.4.4 

func (mr *MockSeriesIteratorMockRecorder) SetIterateEqualTimestampStrategy(strategy interface{}) *gomock.Call

SetIterateEqualTimestampStrategy indicates an expected call of SetIterateEqualTimestampStrategy.

func (*MockSeriesIteratorMockRecorder) Start 

func (mr *MockSeriesIteratorMockRecorder) Start() *gomock.Call

Start indicates an expected call of Start.

func (*MockSeriesIteratorMockRecorder) Stats added in v0.15.0 

func (mr *MockSeriesIteratorMockRecorder) Stats() *gomock.Call

Stats indicates an expected call of Stats.

func (*MockSeriesIteratorMockRecorder) Tags 

func (mr *MockSeriesIteratorMockRecorder) Tags() *gomock.Call

Tags indicates an expected call of Tags.

type MockSeriesIteratorPool 

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

MockSeriesIteratorPool is a mock of SeriesIteratorPool interface.

func NewMockSeriesIteratorPool 

func NewMockSeriesIteratorPool(ctrl *gomock.Controller) *MockSeriesIteratorPool

NewMockSeriesIteratorPool creates a new mock instance.

func (*MockSeriesIteratorPool) EXPECT 

func (m *MockSeriesIteratorPool) EXPECT() *MockSeriesIteratorPoolMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockSeriesIteratorPool) Get 

func (m *MockSeriesIteratorPool) Get() SeriesIterator

Get mocks base method.

func (*MockSeriesIteratorPool) Init 

func (m *MockSeriesIteratorPool) Init()

Init mocks base method.

func (*MockSeriesIteratorPool) Put 

func (m *MockSeriesIteratorPool) Put(iter SeriesIterator)

Put mocks base method.

type MockSeriesIteratorPoolMockRecorder 

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

MockSeriesIteratorPoolMockRecorder is the mock recorder for MockSeriesIteratorPool.

func (*MockSeriesIteratorPoolMockRecorder) Get 

func (mr *MockSeriesIteratorPoolMockRecorder) Get() *gomock.Call

Get indicates an expected call of Get.

func (*MockSeriesIteratorPoolMockRecorder) Init 

func (mr *MockSeriesIteratorPoolMockRecorder) Init() *gomock.Call

Init indicates an expected call of Init.

func (*MockSeriesIteratorPoolMockRecorder) Put 

func (mr *MockSeriesIteratorPoolMockRecorder) Put(iter interface{}) *gomock.Call

Put indicates an expected call of Put.

type MockSeriesIterators 

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

MockSeriesIterators is a mock of SeriesIterators interface.

func NewMockSeriesIterators 

func NewMockSeriesIterators(ctrl *gomock.Controller) *MockSeriesIterators

NewMockSeriesIterators creates a new mock instance.

func (*MockSeriesIterators) Close 

func (m *MockSeriesIterators) Close()

Close mocks base method.

func (*MockSeriesIterators) EXPECT 

func (m *MockSeriesIterators) EXPECT() *MockSeriesIteratorsMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockSeriesIterators) Iters 

func (m *MockSeriesIterators) Iters() []SeriesIterator

Iters mocks base method.

func (*MockSeriesIterators) Len 

func (m *MockSeriesIterators) Len() int

Len mocks base method.

type MockSeriesIteratorsMockRecorder 

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

MockSeriesIteratorsMockRecorder is the mock recorder for MockSeriesIterators.

func (*MockSeriesIteratorsMockRecorder) Close 

func (mr *MockSeriesIteratorsMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockSeriesIteratorsMockRecorder) Iters 

func (mr *MockSeriesIteratorsMockRecorder) Iters() *gomock.Call

Iters indicates an expected call of Iters.

func (*MockSeriesIteratorsMockRecorder) Len 

func (mr *MockSeriesIteratorsMockRecorder) Len() *gomock.Call

Len indicates an expected call of Len.

type MultiReaderIterator 

type MultiReaderIterator interface {
	Iterator

	// Reset resets the iterator to read from a slice of readers
	// with a new schema (for schema aware iterators).
	Reset(readers []xio.SegmentReader, start xtime.UnixNano,
		blockSize time.Duration, schema namespace.SchemaDescr)

	// Reset resets the iterator to read from a slice of slice readers
	// with a new schema (for schema aware iterators).
	ResetSliceOfSlices(
		readers xio.ReaderSliceOfSlicesIterator,
		schema namespace.SchemaDescr,
	)

	// Readers exposes the underlying ReaderSliceOfSlicesIterator
	// for this MultiReaderIterator.
	Readers() xio.ReaderSliceOfSlicesIterator

	// Schema exposes the underlying SchemaDescr for this MultiReaderIterator.
	Schema() namespace.SchemaDescr
}

MultiReaderIterator is an iterator that iterates in order over a list of sets of internally ordered but not collectively in order readers, it also deduplicates datapoints.

func NewMultiReaderIterator 

func NewMultiReaderIterator(
	iteratorAlloc ReaderIteratorAllocate,
	pool MultiReaderIteratorPool,
) MultiReaderIterator

NewMultiReaderIterator creates a new multi-reader iterator.

type MultiReaderIteratorArrayPool 

type MultiReaderIteratorArrayPool interface {
	// Init initializes the pool.
	Init()

	// Get provides a MultiReaderIterator array from the pool.
	Get(size int) []MultiReaderIterator

	// Put returns a MultiReaderIterator array to the pool.
	Put(iters []MultiReaderIterator)
}

MultiReaderIteratorArrayPool provides a pool for MultiReaderIterator arrays.

func NewMultiReaderIteratorArrayPool 

func NewMultiReaderIteratorArrayPool(sizes []pool.Bucket) MultiReaderIteratorArrayPool

NewMultiReaderIteratorArrayPool creates a new pool

type MultiReaderIteratorPool 

type MultiReaderIteratorPool interface {
	// Init initializes the pool.
	Init(alloc ReaderIteratorAllocate)

	// Get provides a MultiReaderIterator from the pool.
	Get() MultiReaderIterator

	// Put returns a MultiReaderIterator to the pool.
	Put(iter MultiReaderIterator)
}

MultiReaderIteratorPool provides a pool for MultiReaderIterators.

func NewMultiReaderIteratorPool 

func NewMultiReaderIteratorPool(opts pool.ObjectPoolOptions) MultiReaderIteratorPool

NewMultiReaderIteratorPool creates a new pool for MultiReaderIterators.

type MutableSeriesIterators 

type MutableSeriesIterators interface {
	SeriesIterators

	// Reset the iters collection to a size for reuse.
	Reset(size int)

	// Cap returns the capacity of the iters.
	Cap() int

	// SetAt sets a SeriesIterator to the given index.
	SetAt(idx int, iter SeriesIterator)
}

MutableSeriesIterators is a mutable SeriesIterators.

func NewSeriesIterators 

func NewSeriesIterators(
	iters []SeriesIterator,
	pool MutableSeriesIteratorsPool,
) MutableSeriesIterators

NewSeriesIterators creates a new series iterators collection

type MutableSeriesIteratorsPool 

type MutableSeriesIteratorsPool interface {
	// Init initializes the pool.
	Init()

	// Get provides a MutableSeriesIterators from the pool.
	Get(size int) MutableSeriesIterators

	// Put returns a MutableSeriesIterators to the pool.
	Put(iters MutableSeriesIterators)
}

MutableSeriesIteratorsPool provides a pool for MutableSeriesIterators.

func NewMutableSeriesIteratorsPool 

func NewMutableSeriesIteratorsPool(sizes []pool.Bucket) MutableSeriesIteratorsPool

NewMutableSeriesIteratorsPool creates a new pool

type NewDecoderFn 

type NewDecoderFn func() Decoder

NewDecoderFn creates a new decoder.

type NewEncoderFn 

type NewEncoderFn func(start time.Time, bytes []byte) Encoder

NewEncoderFn creates a new encoder.

type OStream 

type OStream interface {
	// Len returns the length of the OStream.
	Len() int
	// Empty returns whether the OStream is empty.
	Empty() bool

	// WriteBit writes the last bit of v.
	WriteBit(v Bit)

	// WriteBits writes the lowest numBits of v to the stream, starting
	// from the most significant bit to the least significant bit.
	WriteBits(v uint64, numBits int)

	// WriteByte writes the last byte of v.
	WriteByte(v byte)

	// WriteBytes writes a byte slice.
	WriteBytes(bytes []byte)

	// Write writes a byte slice. This method exists in addition to WriteBytes()
	// to satisfy the io.Writer interface.
	Write(bytes []byte) (int, error)

	// Reset resets the ostream.
	Reset(buffer checked.Bytes)

	// Discard takes the ref to the checked bytes from the OStream.
	Discard() checked.Bytes

	// RawBytes returns the OStream's raw bytes. Note that this does not transfer
	// ownership of the data and bypasses the checked.Bytes accounting so
	// callers should:
	//     1. Only use the returned slice as a "read-only" snapshot of the
	//        data in a context where the caller has at least a read lock
	//        on the ostream itself.
	//     2. Use this function with care.
	RawBytes() ([]byte, int)

	// CheckedBytes returns the written stream as checked bytes.
	CheckedBytes() (checked.Bytes, int)
}

OStream encapsulates a writable stream.

func NewOStream 

func NewOStream(
	bytes checked.Bytes,
	initAllocIfEmpty bool,
	bytesPool pool.CheckedBytesPool,
) OStream

NewOStream creates a new Ostream

type Options 

type Options interface {
	// SetDefaultTimeUnit sets the default time unit for the encoder.
	SetDefaultTimeUnit(tu xtime.Unit) Options

	// DefaultTimeUnit returns the default time unit for the encoder.
	DefaultTimeUnit() xtime.Unit

	// SetTimeEncodingSchemes sets the time encoding schemes for different time units.
	SetTimeEncodingSchemes(value map[xtime.Unit]TimeEncodingScheme) Options

	// TimeEncodingSchemes returns the time encoding schemes for different time units.
	TimeEncodingSchemes() TimeEncodingSchemes

	// SetMarkerEncodingScheme sets the marker encoding scheme.
	SetMarkerEncodingScheme(value *MarkerEncodingScheme) Options

	// MarkerEncodingScheme returns the marker encoding scheme.
	MarkerEncodingScheme() *MarkerEncodingScheme

	// SetEncoderPool sets the encoder pool.
	SetEncoderPool(value EncoderPool) Options

	// EncoderPool returns the encoder pool.
	EncoderPool() EncoderPool

	// SetReaderIteratorPool sets the ReaderIteratorPool.
	SetReaderIteratorPool(value ReaderIteratorPool) Options

	// ReaderIteratorPool returns the ReaderIteratorPool.
	ReaderIteratorPool() ReaderIteratorPool

	// SetBytesPool sets the bytes pool.
	SetBytesPool(value pool.CheckedBytesPool) Options

	// BytesPool returns the bytes pool.
	BytesPool() pool.CheckedBytesPool

	// SetSegmentReaderPool sets the segment reader pool.
	SetSegmentReaderPool(value xio.SegmentReaderPool) Options

	// SegmentReaderPool returns the segment reader pool.
	SegmentReaderPool() xio.SegmentReaderPool

	// SetCheckedBytesWrapperPool sets the checked bytes wrapper pool.
	SetCheckedBytesWrapperPool(value xpool.CheckedBytesWrapperPool) Options

	// CheckedBytesWrapperPool returns the checked bytes wrapper pool.
	CheckedBytesWrapperPool() xpool.CheckedBytesWrapperPool

	// SetByteFieldDictionaryLRUSize sets theByteFieldDictionaryLRUSize which controls
	// how many recently seen byte field values will be maintained in the compression
	// dictionaries LRU when compressing / decompressing byte fields in ProtoBuf messages.
	// Increasing this value can potentially lead to better compression at the cost of
	// using more memory for storing metadata when compressing / decompressing.
	SetByteFieldDictionaryLRUSize(value int) Options

	// ByteFieldDictionaryLRUSize returns the ByteFieldDictionaryLRUSize.
	ByteFieldDictionaryLRUSize() int

	// SetIStreamReaderSizeM3TSZ sets the IStream bufio reader size
	// for m3tsz encoding iteration.
	SetIStreamReaderSizeM3TSZ(value int) Options

	// IStreamReaderSizeM3TSZ returns the IStream bufio reader size
	// for m3tsz encoding iteration.
	IStreamReaderSizeM3TSZ() int

	// SetIStreamReaderSizeProto sets the IStream bufio reader size
	// for proto encoding iteration.
	SetIStreamReaderSizeProto(value int) Options

	// SetIStreamReaderSizeProto returns the IStream bufio reader size
	// for proto encoding iteration.
	IStreamReaderSizeProto() int

	// SetMetrics sets the encoding metrics.
	SetMetrics(value Metrics) Options

	// Metrics returns the encoding metrics.
	Metrics() Metrics
}

Options represents different options for encoding time as well as markers.

func NewOptions 

func NewOptions() Options

NewOptions creates a new options.

type ReaderIterator 

type ReaderIterator interface {
	Iterator

	// Reset resets the iterator to read from a new reader with
	// a new schema (for schema aware iterators).
	Reset(reader xio.Reader64, schema namespace.SchemaDescr)
}

ReaderIterator is the interface for a single-reader iterator.

func NewNullReaderIterator 

func NewNullReaderIterator() ReaderIterator

NewNullReaderIterator returns a new reader iterator that performs no operations

type ReaderIteratorAllocate 

type ReaderIteratorAllocate func(reader xio.Reader64, descr namespace.SchemaDescr) ReaderIterator

ReaderIteratorAllocate allocates a ReaderIterator for a pool.

type ReaderIteratorPool 

type ReaderIteratorPool interface {
	// Init initializes the pool.
	Init(alloc ReaderIteratorAllocate)

	// Get provides a ReaderIterator from the pool.
	Get() ReaderIterator

	// Put returns a ReaderIterator to the pool.
	Put(iter ReaderIterator)
}

ReaderIteratorPool provides a pool for ReaderIterators.

func NewReaderIteratorPool 

func NewReaderIteratorPool(opts pool.ObjectPoolOptions) ReaderIteratorPool

NewReaderIteratorPool creates a new pool for ReaderIterators.

type SeriesAccumulatorOptions added in v0.15.2 

type SeriesAccumulatorOptions struct {
	// RetainTags determines if tags should be preserved after the accumulator is
	// exhausted. If set to true, the accumulator retains a copy of the tags.
	RetainTags bool
}

SeriesAccumulatorOptions are options for a SeriesIteratorAccumulator.

type SeriesIterator 

type SeriesIterator interface {
	Iterator

	// ID gets the ID of the series.
	ID() ident.ID

	// Namespace gets the namespace of the series.
	Namespace() ident.ID

	// Start returns the start time filter specified for the iterator.
	Start() xtime.UnixNano

	// End returns the end time filter specified for the iterator.
	End() xtime.UnixNano

	// Reset resets the iterator to read from a set of iterators from different
	// replicas, one  must note that this can be an array with nil entries if
	// some replicas did not return successfully.
	// NB: the SeriesIterator assumes ownership of the provided ids, this
	// includes calling `id.Finalize()` upon iter.Close().
	Reset(opts SeriesIteratorOptions)

	// SetIterateEqualTimestampStrategy sets the equal timestamp strategy of how
	// to select a value when the timestamp matches differing values with the same
	// timestamp from different replicas.
	// It can be set at any time and will apply to the current value returned
	// from the iterator immediately.
	SetIterateEqualTimestampStrategy(strategy IterateEqualTimestampStrategy)

	// Stats provides information for this SeriesIterator.
	Stats() (SeriesIteratorStats, error)

	// Replicas exposes the underlying MultiReaderIterator slice
	// for this SeriesIterator.
	Replicas() ([]MultiReaderIterator, error)

	// Tags returns an iterator over the tags associated with the ID.
	Tags() ident.TagIterator
}

SeriesIterator is an iterator that iterates over a set of iterators from different replicas and de-dupes & merges results from the replicas for a given series while also applying a time filter on top of the values in case replicas returned values out of range on either end.

func NewSeriesIterator 

func NewSeriesIterator(
	opts SeriesIteratorOptions,
	pool SeriesIteratorPool,
) SeriesIterator

NewSeriesIterator creates a new series iterator. NB: The returned SeriesIterator assumes ownership of the provided `ident.ID`.

type SeriesIteratorAccumulator added in v0.15.2 

type SeriesIteratorAccumulator interface {
	SeriesIterator

	// Add adds a series iterator.
	Add(it SeriesIterator) error
}

SeriesIteratorAccumulator is an accumulator for SeriesIterator iterators, that gathers incoming SeriesIterators and builds a unified SeriesIterator.

func NewSeriesIteratorAccumulator added in v0.15.2 

func NewSeriesIteratorAccumulator(
	iter SeriesIterator,
	opts SeriesAccumulatorOptions,
) (SeriesIteratorAccumulator, error)

NewSeriesIteratorAccumulator creates a new series iterator.

type SeriesIteratorConsolidator added in v0.15.0 

type SeriesIteratorConsolidator interface {
	// ConsolidateReplicas consolidates MultiReaderIterator slices.
	ConsolidateReplicas(replicas []MultiReaderIterator) ([]MultiReaderIterator, error)
}

SeriesIteratorConsolidator optionally defines methods to consolidate series iterators.

type SeriesIteratorOptions added in v0.4.4 

type SeriesIteratorOptions struct {
	ID                            ident.ID
	Namespace                     ident.ID
	Tags                          ident.TagIterator
	Replicas                      []MultiReaderIterator
	StartInclusive                xtime.UnixNano
	EndExclusive                  xtime.UnixNano
	IterateEqualTimestampStrategy IterateEqualTimestampStrategy
	SeriesIteratorConsolidator    SeriesIteratorConsolidator
}

SeriesIteratorOptions is a set of options for using a series iterator.

type SeriesIteratorPool 

type SeriesIteratorPool interface {
	// Init initializes the pool.
	Init()

	// Get provides a SeriesIterator from the pool.
	Get() SeriesIterator

	// Put returns a SeriesIterator to the pool.
	Put(iter SeriesIterator)
}

SeriesIteratorPool provides a pool for SeriesIterator.

func NewSeriesIteratorPool 

func NewSeriesIteratorPool(opts pool.ObjectPoolOptions) SeriesIteratorPool

NewSeriesIteratorPool creates a new pool for SeriesIterators.

type SeriesIteratorStats added in v0.15.0 

type SeriesIteratorStats struct {
	// ApproximateSizeInBytes approximates how much data is contained within the
	// SeriesIterator, in bytes.
	ApproximateSizeInBytes int
}

SeriesIteratorStats contains information about a SeriesIterator.

type SeriesIterators 

type SeriesIterators interface {
	// Iters returns the array of series iterators.
	Iters() []SeriesIterator

	// Len returns the count of iterators in the collection.
	Len() int

	// Close closes all iterators contained within the collection.
	Close()
}

SeriesIterators is a collection of SeriesIterator that can close all iterators. 

var EmptySeriesIterators SeriesIterators = emptyIters{}

EmptySeriesIterators is an empty SeriesIterators.

type TimeBucket 

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

TimeBucket represents a bucket for encoding time values.

func NewTimeBucket added in v1.2.0 

func NewTimeBucket(opcode uint64, numOpcodeBits, numValueBits int) TimeBucket

NewTimeBucket creates a new time bucket.

func (*TimeBucket) Max 

func (tb *TimeBucket) Max() int64

Max is the maximum time value accepted in this range.

func (*TimeBucket) Min 

func (tb *TimeBucket) Min() int64

Min is the minimum time value accepted in this range.

func (*TimeBucket) NumOpcodeBits 

func (tb *TimeBucket) NumOpcodeBits() int

NumOpcodeBits is the number of bits used to write the opcode.

func (*TimeBucket) NumValueBits 

func (tb *TimeBucket) NumValueBits() int

NumValueBits is the number of bits used to write the time value.

func (*TimeBucket) Opcode 

func (tb *TimeBucket) Opcode() uint64

Opcode is the opcode prefix used to encode all time values in this range.

type TimeEncodingScheme 

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

TimeEncodingScheme captures information related to time encoding.

func NewTimeEncodingScheme added in v1.2.0 

func NewTimeEncodingScheme(numValueBitsForBuckets []int, numValueBitsForDefault int) TimeEncodingScheme

NewTimeEncodingScheme creates a new time encoding scheme. NB(xichen): numValueBitsForBuckets should be ordered by value in ascending order (smallest value first).

func (*TimeEncodingScheme) Buckets 

func (tes *TimeEncodingScheme) Buckets() []TimeBucket

Buckets are the ordered time buckets used to encode non-zero, non-default time values.

func (*TimeEncodingScheme) DefaultBucket 

func (tes *TimeEncodingScheme) DefaultBucket() *TimeBucket

DefaultBucket is the time bucket for catching all other time values not included in the regular buckets.

func (*TimeEncodingScheme) ZeroBucket 

func (tes *TimeEncodingScheme) ZeroBucket() *TimeBucket

ZeroBucket is time bucket for encoding zero time values.

type TimeEncodingSchemes 

type TimeEncodingSchemes []TimeEncodingScheme

TimeEncodingSchemes defines the time encoding schemes for different time units.

func NewTimeEncodingSchemes added in v1.2.0 

func NewTimeEncodingSchemes(schemes map[xtime.Unit]TimeEncodingScheme) TimeEncodingSchemes

NewTimeEncodingSchemes converts the unit-to-scheme mapping to the underlying TimeEncodingSchemes used for lookups.

func (TimeEncodingSchemes) SchemeForUnit added in v0.15.0 

func (s TimeEncodingSchemes) SchemeForUnit(u xtime.Unit) (*TimeEncodingScheme, bool)

SchemeForUnit returns the corresponding TimeEncodingScheme for the provided unit. Returns false if the unit does not match a scheme or is invalid.

type TimestampEncoderMetrics added in v1.2.0 

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

TimestampEncoderMetrics contains timestamp encoder metrics.

func (*TimestampEncoderMetrics) IncAnnotationRewritten added in v1.2.0 

func (m *TimestampEncoderMetrics) IncAnnotationRewritten()

IncAnnotationRewritten increments annotation rewritten counter.

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.