encoding

package
v0.15.11 Latest Latest
Warning

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

 Go to latest Published: Aug 22, 2020 License: Apache-2.0 Imports: 20 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 values in a uint64

func SignExtend ¶ 

func SignExtend(v uint64, numBits uint) 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 io.Reader) 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 context.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)

	// LastAnnotation returns the last encoded datapoint, useful for
	// de-duplicating encoded values. If there are no previously encoded values
	// an error is returned.
	LastAnnotation() (ts.Annotation, 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 time.Time, capacity int, schema namespace.SchemaDescr)

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

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

	// DiscardReset will take ownership of the encoder data and reset the encoder for use.
	// DiscardReset sets up the schema for schema-aware encoders such as proto encoders.
	DiscardReset(t time.Time, 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 interface {
	// Read reads len(b) bytes.
	Read([]byte) (int, error)

	// ReadBit reads the next Bit.
	ReadBit() (Bit, error)

	// ReadByte reads the next Byte.
	ReadByte() (byte, error)

	// ReadBits reads the next Bits.
	ReadBits(numBits uint) (uint64, error)

	// PeekBits looks at the next Bits, but doesn't move the pos.
	PeekBits(numBits uint) (uint64, error)

	// RemainingBitsInCurrentByte returns the number of bits remaining to
	// be read in the current byte.
	RemainingBitsInCurrentByte() uint

	// Reset resets the IStream.
	Reset(r io.Reader)
}

IStream encapsulates a readable stream.

func NewIStream ¶ 

func NewIStream(reader io.Reader, bufioSize int) IStream

NewIStream creates a new 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 interface {

	// Opcode returns the marker opcode.
	Opcode() uint64

	// NumOpcodeBits returns the number of bits used for the opcode.
	NumOpcodeBits() int

	// NumValueBits returns the number of bits used for the marker value.
	NumValueBits() int

	// EndOfStream returns the end of stream marker.
	EndOfStream() Marker

	// Annotation returns the annotation marker.
	Annotation() Marker

	// TimeUnit returns the time unit marker.
	TimeUnit() Marker

	// Tail will return the tail portion of a stream including the relevant bits
	// in the last byte along with the end of stream marker.
	Tail(streamLastByte byte, streamCurrentPosition int) checked.Bytes
}

MarkerEncodingScheme captures the information related to marker encoding.

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 io.Reader) 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 time.Time, 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) LastAnnotation ¶ added in v0.15.0 

func (m *MockEncoder) LastAnnotation() (ts.Annotation, error)

LastAnnotation 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 time.Time, 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) LastAnnotation ¶ added in v0.15.0 

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

LastAnnotation indicates an expected call of LastAnnotation

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 MockIStream ¶ 

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

MockIStream is a mock of IStream interface

func NewMockIStream ¶ 

func NewMockIStream(ctrl *gomock.Controller) *MockIStream

NewMockIStream creates a new mock instance

func (*MockIStream) EXPECT ¶ 

func (m *MockIStream) EXPECT() *MockIStreamMockRecorder

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

func (*MockIStream) PeekBits ¶ 

func (m *MockIStream) PeekBits(numBits uint) (uint64, error)

PeekBits mocks base method

func (*MockIStream) Read ¶ added in v0.8.2 

func (m *MockIStream) Read(arg0 []byte) (int, error)

Read mocks base method

func (*MockIStream) ReadBit ¶ 

func (m *MockIStream) ReadBit() (Bit, error)

ReadBit mocks base method

func (*MockIStream) ReadBits ¶ 

func (m *MockIStream) ReadBits(numBits uint) (uint64, error)

ReadBits mocks base method

func (*MockIStream) ReadByte ¶ 

func (m *MockIStream) ReadByte() (byte, error)

ReadByte mocks base method

func (*MockIStream) RemainingBitsInCurrentByte ¶ added in v0.8.2 

func (m *MockIStream) RemainingBitsInCurrentByte() uint

RemainingBitsInCurrentByte mocks base method

func (*MockIStream) Reset ¶ 

func (m *MockIStream) Reset(r io.Reader)

Reset mocks base method

type MockIStreamMockRecorder ¶ 

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

MockIStreamMockRecorder is the mock recorder for MockIStream

func (*MockIStreamMockRecorder) PeekBits ¶ 

func (mr *MockIStreamMockRecorder) PeekBits(numBits interface{}) *gomock.Call

PeekBits indicates an expected call of PeekBits

func (*MockIStreamMockRecorder) Read ¶ added in v0.8.2 

func (mr *MockIStreamMockRecorder) Read(arg0 interface{}) *gomock.Call

Read indicates an expected call of Read

func (*MockIStreamMockRecorder) ReadBit ¶ 

func (mr *MockIStreamMockRecorder) ReadBit() *gomock.Call

ReadBit indicates an expected call of ReadBit

func (*MockIStreamMockRecorder) ReadBits ¶ 

func (mr *MockIStreamMockRecorder) ReadBits(numBits interface{}) *gomock.Call

ReadBits indicates an expected call of ReadBits

func (*MockIStreamMockRecorder) ReadByte ¶ 

func (mr *MockIStreamMockRecorder) ReadByte() *gomock.Call

ReadByte indicates an expected call of ReadByte

func (*MockIStreamMockRecorder) RemainingBitsInCurrentByte ¶ added in v0.8.2 

func (mr *MockIStreamMockRecorder) RemainingBitsInCurrentByte() *gomock.Call

RemainingBitsInCurrentByte indicates an expected call of RemainingBitsInCurrentByte

func (*MockIStreamMockRecorder) Reset ¶ 

func (mr *MockIStreamMockRecorder) Reset(r interface{}) *gomock.Call

Reset indicates an expected call of Reset

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 time.Time, 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) 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) 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) 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) 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 io.Reader, 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() time.Time

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() time.Time

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() time.Time

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() time.Time

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(arg0 []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(arg0 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 time.Time,
		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 MutliReaderIterator.
	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
}

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 io.Reader, 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 io.Reader, 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() time.Time

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

	// 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([]MultiReaderIterator) ([]MultiReaderIterator, error)
}

SeriesIteratorConsolidator optionally defines methods to consolidate newly reset 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 interface {

	// Opcode is the opcode prefix used to encode all time values in this range.
	Opcode() uint64

	// NumOpcodeBits is the number of bits used to write the opcode.
	NumOpcodeBits() int

	// Min is the minimum time value accepted in this range.
	Min() int64

	// Max is the maximum time value accepted in this range.
	Max() int64

	// NumValueBits is the number of bits used to write the time value.
	NumValueBits() int
}

TimeBucket represents a bucket for encoding time values.

type TimeEncodingScheme ¶ 

type TimeEncodingScheme interface {

	// ZeroBucket is time bucket for encoding zero time values.
	ZeroBucket() TimeBucket

	// Buckets are the ordered time buckets used to encode non-zero, non-default time values.
	Buckets() []TimeBucket

	// DefaultBucket is the time bucket for catching all other time values not included in the regular buckets.
	DefaultBucket() TimeBucket
}

TimeEncodingScheme captures information related to time encoding.

type TimeEncodingSchemes ¶ 

type TimeEncodingSchemes []TimeEncodingScheme

TimeEncodingSchemes defines the time encoding schemes for different time units.

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.

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.