encoding

package
v1.1.0 Latest Latest
Warning

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

Go to latest
Published: Dec 29, 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 bits 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 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 time.Time, 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 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 (*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) 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 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) 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

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

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

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

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

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

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

Current mocks base method

func (*MockMultiReaderIterator) EXPECT

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

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

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

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

func (*MockMultiReaderIteratorArrayPool) Get

Get mocks base method

func (*MockMultiReaderIteratorArrayPool) Init

Init mocks base method

func (*MockMultiReaderIteratorArrayPool) Put

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

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

Close indicates an expected call of Close

func (*MockMultiReaderIteratorMockRecorder) Current

Current indicates an expected call of Current

func (*MockMultiReaderIteratorMockRecorder) Err

Err indicates an expected call of Err

func (*MockMultiReaderIteratorMockRecorder) Next

Next indicates an expected call of Next

func (*MockMultiReaderIteratorMockRecorder) Readers

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

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

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

func (*MockMultiReaderIteratorPool) Get

Get mocks base method

func (*MockMultiReaderIteratorPool) Init

Init mocks base method

func (*MockMultiReaderIteratorPool) Put

Put mocks base method

type MockMultiReaderIteratorPoolMockRecorder

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

MockMultiReaderIteratorPoolMockRecorder is the mock recorder for MockMultiReaderIteratorPool

func (*MockMultiReaderIteratorPoolMockRecorder) Get

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

Cap mocks base method

func (*MockMutableSeriesIterators) Close

func (m *MockMutableSeriesIterators) Close()

Close mocks base method

func (*MockMutableSeriesIterators) EXPECT

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

func (*MockMutableSeriesIterators) Iters

Iters mocks base method

func (*MockMutableSeriesIterators) Len

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

Cap indicates an expected call of Cap

func (*MockMutableSeriesIteratorsMockRecorder) Close

Close indicates an expected call of Close

func (*MockMutableSeriesIteratorsMockRecorder) Iters

Iters indicates an expected call of Iters

func (*MockMutableSeriesIteratorsMockRecorder) Len

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

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

func (*MockMutableSeriesIteratorsPool) Get

Get mocks base method

func (*MockMutableSeriesIteratorsPool) Init

Init mocks base method

func (*MockMutableSeriesIteratorsPool) Put

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

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

Current mocks base method

func (*MockReaderIterator) EXPECT

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

Close indicates an expected call of Close

func (*MockReaderIteratorMockRecorder) Current

Current indicates an expected call of Current

func (*MockReaderIteratorMockRecorder) Err

Err indicates an expected call of Err

func (*MockReaderIteratorMockRecorder) Next

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

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

func (*MockReaderIteratorPool) Get

Get mocks base method

func (*MockReaderIteratorPool) Init

Init mocks base method

func (*MockReaderIteratorPool) Put

Put mocks base method

type MockReaderIteratorPoolMockRecorder

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

MockReaderIteratorPoolMockRecorder is the mock recorder for MockReaderIteratorPool

func (*MockReaderIteratorPoolMockRecorder) Get

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

Current mocks base method

func (*MockSeriesIterator) EXPECT

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

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

Stats mocks base method

func (*MockSeriesIterator) Tags

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

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

Current mocks base method

func (*MockSeriesIteratorAccumulator) EXPECT added in v0.15.2

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

func (*MockSeriesIteratorAccumulator) End added in v0.15.2

End mocks base method

func (*MockSeriesIteratorAccumulator) Err added in v0.15.2

Err mocks base method

func (*MockSeriesIteratorAccumulator) ID added in v0.15.2

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

Next mocks base method

func (*MockSeriesIteratorAccumulator) Replicas added in v0.15.2

Replicas mocks base method

func (*MockSeriesIteratorAccumulator) Reset added in v0.15.2

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

Start mocks base method

func (*MockSeriesIteratorAccumulator) Stats added in v0.15.2

Stats mocks base method

func (*MockSeriesIteratorAccumulator) Tags added in v0.15.2

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

Close indicates an expected call of Close

func (*MockSeriesIteratorAccumulatorMockRecorder) Current added in v0.15.2

Current indicates an expected call of Current

func (*MockSeriesIteratorAccumulatorMockRecorder) End added in v0.15.2

End indicates an expected call of End

func (*MockSeriesIteratorAccumulatorMockRecorder) Err added in v0.15.2

Err indicates an expected call of Err

func (*MockSeriesIteratorAccumulatorMockRecorder) ID added in v0.15.2

ID indicates an expected call of ID

func (*MockSeriesIteratorAccumulatorMockRecorder) Namespace added in v0.15.2

Namespace indicates an expected call of Namespace

func (*MockSeriesIteratorAccumulatorMockRecorder) Next added in v0.15.2

Next indicates an expected call of Next

func (*MockSeriesIteratorAccumulatorMockRecorder) Replicas added in v0.15.2

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

Start indicates an expected call of Start

func (*MockSeriesIteratorAccumulatorMockRecorder) Stats added in v0.15.2

Stats indicates an expected call of Stats

func (*MockSeriesIteratorAccumulatorMockRecorder) Tags added in v0.15.2

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

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

Close indicates an expected call of Close

func (*MockSeriesIteratorMockRecorder) Current

Current indicates an expected call of Current

func (*MockSeriesIteratorMockRecorder) End

End indicates an expected call of End

func (*MockSeriesIteratorMockRecorder) Err

Err indicates an expected call of Err

func (*MockSeriesIteratorMockRecorder) ID

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

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

Start indicates an expected call of Start

func (*MockSeriesIteratorMockRecorder) Stats added in v0.15.0

Stats indicates an expected call of Stats

func (*MockSeriesIteratorMockRecorder) Tags

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

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

func (*MockSeriesIteratorPool) Get

Get mocks base method

func (*MockSeriesIteratorPool) Init

func (m *MockSeriesIteratorPool) Init()

Init mocks base method

func (*MockSeriesIteratorPool) Put

Put mocks base method

type MockSeriesIteratorPoolMockRecorder

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

MockSeriesIteratorPoolMockRecorder is the mock recorder for MockSeriesIteratorPool

func (*MockSeriesIteratorPoolMockRecorder) Get

Get indicates an expected call of Get

func (*MockSeriesIteratorPoolMockRecorder) Init

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

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

Close indicates an expected call of Close

func (*MockSeriesIteratorsMockRecorder) Iters

Iters indicates an expected call of Iters

func (*MockSeriesIteratorsMockRecorder) Len

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 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
}

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(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 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.

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL