encoding

package
v1.2.0 Latest Latest
Warning

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

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

Documentation

Overview

Package encoding is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func LeadingAndTrailingZeros

func LeadingAndTrailingZeros(v uint64) (int, int)

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

func NumSig

func NumSig(v uint64) uint8

NumSig returns the number of significant bits in a uint64.

func SignExtend

func SignExtend(v uint64, numBits uint8) int64

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

func WriteSpecialMarker

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

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

Types

type Bit

type Bit byte

Bit is just a byte.

type Decoder

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

Decoder is the generic interface for different types of decoders.

type Encoder

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

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

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

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

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

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

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

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

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

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

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

Encoder is the generic interface for different types of encoders.

func NewNullEncoder

func NewNullEncoder() Encoder

NewNullEncoder returns a new encoder that performs no operations

type EncoderAllocate

type EncoderAllocate func() Encoder

EncoderAllocate allocates an encoder for a pool.

type EncoderPool

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

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

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

EncoderPool provides a pool for encoders.

func NewEncoderPool

func NewEncoderPool(opts pool.ObjectPoolOptions) EncoderPool

NewEncoderPool creates a new pool

type IStream

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

IStream encapsulates a readable stream.

func NewIStream

func NewIStream(reader64 xio.Reader64) *IStream

NewIStream creates a new IStream

func (*IStream) PeekBits

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

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

func (*IStream) Read added in v0.8.2

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

Read reads len(b) bytes.

func (*IStream) ReadBit

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

ReadBit reads the next Bit.

func (*IStream) ReadBits

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

ReadBits reads the next Bits.

func (*IStream) ReadByte

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

ReadByte reads the next Byte.

func (*IStream) RemainingBitsInCurrentByte added in v0.8.2

func (is *IStream) RemainingBitsInCurrentByte() uint

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

func (*IStream) Reset

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

Reset resets the IStream.

type IterateEqualTimestampStrategy added in v0.4.4

type IterateEqualTimestampStrategy uint8

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

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

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

func ParseIterateEqualTimestampStrategy added in v0.4.4

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

ParseIterateEqualTimestampStrategy parses a IterateEqualTimestampStrategy from a string.

func ValidIterateEqualTimestampStrategies added in v0.4.4

func ValidIterateEqualTimestampStrategies() []IterateEqualTimestampStrategy

ValidIterateEqualTimestampStrategies returns the valid iterate equal timestamp strategies.

func (IterateEqualTimestampStrategy) String added in v0.4.4

func (*IterateEqualTimestampStrategy) UnmarshalYAML added in v0.4.4

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

UnmarshalYAML unmarshals an IterateEqualTimestampStrategy into a valid type from string.

type Iterator

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

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

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

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

Iterator is the generic interface for iterating over encoded data.

type IteratorPools

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

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

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

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

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

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

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

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

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

type Marker

type Marker byte

Marker represents the markers.

type MarkerEncodingScheme

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

MarkerEncodingScheme captures the information related to marker encoding.

func NewMarkerEncodingScheme added in v1.2.0

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

NewMarkerEncodingScheme returns new marker encoding.

func (*MarkerEncodingScheme) Annotation

func (mes *MarkerEncodingScheme) Annotation() Marker

Annotation returns the annotation marker.

func (*MarkerEncodingScheme) EndOfStream

func (mes *MarkerEncodingScheme) EndOfStream() Marker

EndOfStream returns the end of stream marker.

func (*MarkerEncodingScheme) NumOpcodeBits

func (mes *MarkerEncodingScheme) NumOpcodeBits() int

NumOpcodeBits returns the number of bits used for the opcode.

func (*MarkerEncodingScheme) NumValueBits

func (mes *MarkerEncodingScheme) NumValueBits() int

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

func (*MarkerEncodingScheme) Opcode

func (mes *MarkerEncodingScheme) Opcode() uint64

Opcode returns the marker opcode.

func (*MarkerEncodingScheme) Tail

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

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

func (*MarkerEncodingScheme) TimeUnit

func (mes *MarkerEncodingScheme) TimeUnit() Marker

TimeUnit returns the time unit marker.

type Metrics added in v1.2.0

type Metrics struct {
	TimestampEncoder TimestampEncoderMetrics
}

Metrics contains metrics for encoding.

func NewMetrics added in v1.2.0

func NewMetrics(scope tally.Scope) Metrics

NewMetrics returns new Metrics.

type MockDecoder

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

MockDecoder is a mock of Decoder interface.

func NewMockDecoder

func NewMockDecoder(ctrl *gomock.Controller) *MockDecoder

NewMockDecoder creates a new mock instance.

func (*MockDecoder) Decode

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

Decode mocks base method.

func (*MockDecoder) EXPECT

func (m *MockDecoder) EXPECT() *MockDecoderMockRecorder

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

type MockDecoderMockRecorder

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

MockDecoderMockRecorder is the mock recorder for MockDecoder.

func (*MockDecoderMockRecorder) Decode

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

Decode indicates an expected call of Decode.

type MockEncoder

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

MockEncoder is a mock of Encoder interface.

func NewMockEncoder

func NewMockEncoder(ctrl *gomock.Controller) *MockEncoder

NewMockEncoder creates a new mock instance.

func (*MockEncoder) Close

func (m *MockEncoder) Close()

Close mocks base method.

func (*MockEncoder) Discard

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

Discard mocks base method.

func (*MockEncoder) DiscardReset

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

DiscardReset mocks base method.

func (*MockEncoder) EXPECT

func (m *MockEncoder) EXPECT() *MockEncoderMockRecorder

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

func (*MockEncoder) Encode

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

Encode mocks base method.

func (*MockEncoder) LastAnnotationChecksum added in v1.0.0

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

LastAnnotationChecksum mocks base method.

func (*MockEncoder) LastEncoded added in v0.4.4

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

LastEncoded mocks base method.

func (*MockEncoder) Len

func (m *MockEncoder) Len() int

Len mocks base method.

func (*MockEncoder) NumEncoded added in v0.4.4

func (m *MockEncoder) NumEncoded() int

NumEncoded mocks base method.

func (*MockEncoder) Reset

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

Reset mocks base method.

func (*MockEncoder) SetSchema added in v0.9.2

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

SetSchema mocks base method.

func (*MockEncoder) Stream

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

Stream mocks base method.

type MockEncoderMockRecorder

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

MockEncoderMockRecorder is the mock recorder for MockEncoder.

func (*MockEncoderMockRecorder) Close

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

Close indicates an expected call of Close.

func (*MockEncoderMockRecorder) Discard

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

Discard indicates an expected call of Discard.

func (*MockEncoderMockRecorder) DiscardReset

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

DiscardReset indicates an expected call of DiscardReset.

func (*MockEncoderMockRecorder) Encode

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

Encode indicates an expected call of Encode.

func (*MockEncoderMockRecorder) LastAnnotationChecksum added in v1.0.0

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

LastAnnotationChecksum indicates an expected call of LastAnnotationChecksum.

func (*MockEncoderMockRecorder) LastEncoded added in v0.4.4

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

LastEncoded indicates an expected call of LastEncoded.

func (*MockEncoderMockRecorder) Len

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

Len indicates an expected call of Len.

func (*MockEncoderMockRecorder) NumEncoded added in v0.4.4

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

NumEncoded indicates an expected call of NumEncoded.

func (*MockEncoderMockRecorder) Reset

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

Reset indicates an expected call of Reset.

func (*MockEncoderMockRecorder) SetSchema added in v0.9.2

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

SetSchema indicates an expected call of SetSchema.

func (*MockEncoderMockRecorder) Stream

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

Stream indicates an expected call of Stream.

type MockEncoderPool

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

MockEncoderPool is a mock of EncoderPool interface.

func NewMockEncoderPool

func NewMockEncoderPool(ctrl *gomock.Controller) *MockEncoderPool

NewMockEncoderPool creates a new mock instance.

func (*MockEncoderPool) EXPECT

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 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 time0.UnixNano, blockSize time.Duration, schema namespace.SchemaDescr)

Reset mocks base method.

func (*MockMultiReaderIterator) ResetSliceOfSlices

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

ResetSliceOfSlices mocks base method.

func (*MockMultiReaderIterator) Schema added in v0.15.0

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) Metrics added in v1.2.0

func (m *MockOptions) Metrics() Metrics

Metrics mocks base method.

func (*MockOptions) ReaderIteratorPool

func (m *MockOptions) ReaderIteratorPool() ReaderIteratorPool

ReaderIteratorPool mocks base method.

func (*MockOptions) SegmentReaderPool

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

SegmentReaderPool mocks base method.

func (*MockOptions) SetByteFieldDictionaryLRUSize added in v0.8.2

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

SetByteFieldDictionaryLRUSize mocks base method.

func (*MockOptions) SetBytesPool

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

SetBytesPool mocks base method.

func (*MockOptions) SetCheckedBytesWrapperPool added in v0.15.0

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

SetCheckedBytesWrapperPool mocks base method.

func (*MockOptions) SetDefaultTimeUnit

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

SetDefaultTimeUnit mocks base method.

func (*MockOptions) SetEncoderPool

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

SetEncoderPool mocks base method.

func (*MockOptions) SetIStreamReaderSizeM3TSZ added in v0.14.1

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

SetIStreamReaderSizeM3TSZ mocks base method.

func (*MockOptions) SetIStreamReaderSizeProto added in v0.14.1

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

SetIStreamReaderSizeProto mocks base method.

func (*MockOptions) SetMarkerEncodingScheme

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

SetMarkerEncodingScheme mocks base method.

func (*MockOptions) SetMetrics added in v1.2.0

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

SetMetrics mocks base method.

func (*MockOptions) SetReaderIteratorPool

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

SetReaderIteratorPool mocks base method.

func (*MockOptions) SetSegmentReaderPool

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

SetSegmentReaderPool mocks base method.

func (*MockOptions) SetTimeEncodingSchemes

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

SetTimeEncodingSchemes mocks base method.

func (*MockOptions) TimeEncodingSchemes

func (m *MockOptions) TimeEncodingSchemes() TimeEncodingSchemes

TimeEncodingSchemes mocks base method.

type MockOptionsMockRecorder

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

MockOptionsMockRecorder is the mock recorder for MockOptions.

func (*MockOptionsMockRecorder) ByteFieldDictionaryLRUSize added in v0.8.2

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

ByteFieldDictionaryLRUSize indicates an expected call of ByteFieldDictionaryLRUSize.

func (*MockOptionsMockRecorder) BytesPool

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

BytesPool indicates an expected call of BytesPool.

func (*MockOptionsMockRecorder) CheckedBytesWrapperPool added in v0.15.0

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

CheckedBytesWrapperPool indicates an expected call of CheckedBytesWrapperPool.

func (*MockOptionsMockRecorder) DefaultTimeUnit

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

DefaultTimeUnit indicates an expected call of DefaultTimeUnit.

func (*MockOptionsMockRecorder) EncoderPool

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

EncoderPool indicates an expected call of EncoderPool.

func (*MockOptionsMockRecorder) IStreamReaderSizeM3TSZ added in v0.14.1

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

IStreamReaderSizeM3TSZ indicates an expected call of IStreamReaderSizeM3TSZ.

func (*MockOptionsMockRecorder) IStreamReaderSizeProto added in v0.14.1

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

IStreamReaderSizeProto indicates an expected call of IStreamReaderSizeProto.

func (*MockOptionsMockRecorder) MarkerEncodingScheme

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

MarkerEncodingScheme indicates an expected call of MarkerEncodingScheme.

func (*MockOptionsMockRecorder) Metrics added in v1.2.0

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

Metrics indicates an expected call of Metrics.

func (*MockOptionsMockRecorder) ReaderIteratorPool

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

ReaderIteratorPool indicates an expected call of ReaderIteratorPool.

func (*MockOptionsMockRecorder) SegmentReaderPool

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

SegmentReaderPool indicates an expected call of SegmentReaderPool.

func (*MockOptionsMockRecorder) SetByteFieldDictionaryLRUSize added in v0.8.2

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

SetByteFieldDictionaryLRUSize indicates an expected call of SetByteFieldDictionaryLRUSize.

func (*MockOptionsMockRecorder) SetBytesPool

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

SetBytesPool indicates an expected call of SetBytesPool.

func (*MockOptionsMockRecorder) SetCheckedBytesWrapperPool added in v0.15.0

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

SetCheckedBytesWrapperPool indicates an expected call of SetCheckedBytesWrapperPool.

func (*MockOptionsMockRecorder) SetDefaultTimeUnit

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

SetDefaultTimeUnit indicates an expected call of SetDefaultTimeUnit.

func (*MockOptionsMockRecorder) SetEncoderPool

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

SetEncoderPool indicates an expected call of SetEncoderPool.

func (*MockOptionsMockRecorder) SetIStreamReaderSizeM3TSZ added in v0.14.1

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

SetIStreamReaderSizeM3TSZ indicates an expected call of SetIStreamReaderSizeM3TSZ.

func (*MockOptionsMockRecorder) SetIStreamReaderSizeProto added in v0.14.1

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

SetIStreamReaderSizeProto indicates an expected call of SetIStreamReaderSizeProto.

func (*MockOptionsMockRecorder) SetMarkerEncodingScheme

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

SetMarkerEncodingScheme indicates an expected call of SetMarkerEncodingScheme.

func (*MockOptionsMockRecorder) SetMetrics added in v1.2.0

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

SetMetrics indicates an expected call of SetMetrics.

func (*MockOptionsMockRecorder) SetReaderIteratorPool

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

SetReaderIteratorPool indicates an expected call of SetReaderIteratorPool.

func (*MockOptionsMockRecorder) SetSegmentReaderPool

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

SetSegmentReaderPool indicates an expected call of SetSegmentReaderPool.

func (*MockOptionsMockRecorder) SetTimeEncodingSchemes

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

SetTimeEncodingSchemes indicates an expected call of SetTimeEncodingSchemes.

func (*MockOptionsMockRecorder) TimeEncodingSchemes

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

TimeEncodingSchemes indicates an expected call of TimeEncodingSchemes.

type MockReaderIterator

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

MockReaderIterator is a mock of ReaderIterator interface.

func NewMockReaderIterator

func NewMockReaderIterator(ctrl *gomock.Controller) *MockReaderIterator

NewMockReaderIterator creates a new mock instance.

func (*MockReaderIterator) Close

func (m *MockReaderIterator) Close()

Close mocks base method.

func (*MockReaderIterator) Current

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 xio.Reader64, schema namespace.SchemaDescr)

Reset mocks base method.

type MockReaderIteratorMockRecorder

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

MockReaderIteratorMockRecorder is the mock recorder for MockReaderIterator.

func (*MockReaderIteratorMockRecorder) Close

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

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() time0.UnixNano

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 xtime.UnixNano,
		blockSize time.Duration, schema namespace.SchemaDescr)

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

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

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

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

func NewMultiReaderIterator

func NewMultiReaderIterator(
	iteratorAlloc ReaderIteratorAllocate,
	pool MultiReaderIteratorPool,
) MultiReaderIterator

NewMultiReaderIterator creates a new multi-reader iterator.

type MultiReaderIteratorArrayPool

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

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

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

MultiReaderIteratorArrayPool provides a pool for MultiReaderIterator arrays.

func NewMultiReaderIteratorArrayPool

func NewMultiReaderIteratorArrayPool(sizes []pool.Bucket) MultiReaderIteratorArrayPool

NewMultiReaderIteratorArrayPool creates a new pool

type MultiReaderIteratorPool

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

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

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

MultiReaderIteratorPool provides a pool for MultiReaderIterators.

func NewMultiReaderIteratorPool

func NewMultiReaderIteratorPool(opts pool.ObjectPoolOptions) MultiReaderIteratorPool

NewMultiReaderIteratorPool creates a new pool for MultiReaderIterators.

type MutableSeriesIterators

type MutableSeriesIterators interface {
	SeriesIterators

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

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

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

MutableSeriesIterators is a mutable SeriesIterators.

func NewSeriesIterators

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

NewSeriesIterators creates a new series iterators collection

type MutableSeriesIteratorsPool

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

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

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

MutableSeriesIteratorsPool provides a pool for MutableSeriesIterators.

func NewMutableSeriesIteratorsPool

func NewMutableSeriesIteratorsPool(sizes []pool.Bucket) MutableSeriesIteratorsPool

NewMutableSeriesIteratorsPool creates a new pool

type NewDecoderFn

type NewDecoderFn func() Decoder

NewDecoderFn creates a new decoder.

type NewEncoderFn

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

NewEncoderFn creates a new encoder.

type OStream

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

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

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

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

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

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

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

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

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

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

OStream encapsulates a writable stream.

func NewOStream

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

NewOStream creates a new Ostream

type Options

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

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

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

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

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

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

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

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

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

	// ReaderIteratorPool returns the ReaderIteratorPool.
	ReaderIteratorPool() ReaderIteratorPool

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

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

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

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

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

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

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

	// ByteFieldDictionaryLRUSize returns the ByteFieldDictionaryLRUSize.
	ByteFieldDictionaryLRUSize() int

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

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

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

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

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

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

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

func NewOptions

func NewOptions() Options

NewOptions creates a new options.

type ReaderIterator

type ReaderIterator interface {
	Iterator

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

ReaderIterator is the interface for a single-reader iterator.

func NewNullReaderIterator

func NewNullReaderIterator() ReaderIterator

NewNullReaderIterator returns a new reader iterator that performs no operations

type ReaderIteratorAllocate

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

ReaderIteratorAllocate allocates a ReaderIterator for a pool.

type ReaderIteratorPool

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

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

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

ReaderIteratorPool provides a pool for ReaderIterators.

func NewReaderIteratorPool

func NewReaderIteratorPool(opts pool.ObjectPoolOptions) ReaderIteratorPool

NewReaderIteratorPool creates a new pool for ReaderIterators.

type SeriesAccumulatorOptions added in v0.15.2

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

SeriesAccumulatorOptions are options for a SeriesIteratorAccumulator.

type SeriesIterator

type SeriesIterator interface {
	Iterator

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

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

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

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

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

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

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

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

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

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

func NewSeriesIterator

func NewSeriesIterator(
	opts SeriesIteratorOptions,
	pool SeriesIteratorPool,
) SeriesIterator

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

type SeriesIteratorAccumulator added in v0.15.2

type SeriesIteratorAccumulator interface {
	SeriesIterator

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

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

func NewSeriesIteratorAccumulator added in v0.15.2

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

NewSeriesIteratorAccumulator creates a new series iterator.

type SeriesIteratorConsolidator added in v0.15.0

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

SeriesIteratorConsolidator optionally defines methods to consolidate series iterators.

type SeriesIteratorOptions added in v0.4.4

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

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

type SeriesIteratorPool

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

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

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

SeriesIteratorPool provides a pool for SeriesIterator.

func NewSeriesIteratorPool

func NewSeriesIteratorPool(opts pool.ObjectPoolOptions) SeriesIteratorPool

NewSeriesIteratorPool creates a new pool for SeriesIterators.

type SeriesIteratorStats added in v0.15.0

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

SeriesIteratorStats contains information about a SeriesIterator.

type SeriesIterators

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

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

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

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

var EmptySeriesIterators SeriesIterators = emptyIters{}

EmptySeriesIterators is an empty SeriesIterators.

type TimeBucket

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

TimeBucket represents a bucket for encoding time values.

func NewTimeBucket added in v1.2.0

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

NewTimeBucket creates a new time bucket.

func (*TimeBucket) Max

func (tb *TimeBucket) Max() int64

Max is the maximum time value accepted in this range.

func (*TimeBucket) Min

func (tb *TimeBucket) Min() int64

Min is the minimum time value accepted in this range.

func (*TimeBucket) NumOpcodeBits

func (tb *TimeBucket) NumOpcodeBits() int

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

func (*TimeBucket) NumValueBits

func (tb *TimeBucket) NumValueBits() int

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

func (*TimeBucket) Opcode

func (tb *TimeBucket) Opcode() uint64

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

type TimeEncodingScheme

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

TimeEncodingScheme captures information related to time encoding.

func NewTimeEncodingScheme added in v1.2.0

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

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

func (*TimeEncodingScheme) Buckets

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

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

func (*TimeEncodingScheme) DefaultBucket

func (tes *TimeEncodingScheme) DefaultBucket() *TimeBucket

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

func (*TimeEncodingScheme) ZeroBucket

func (tes *TimeEncodingScheme) ZeroBucket() *TimeBucket

ZeroBucket is time bucket for encoding zero time values.

type TimeEncodingSchemes

type TimeEncodingSchemes []TimeEncodingScheme

TimeEncodingSchemes defines the time encoding schemes for different time units.

func NewTimeEncodingSchemes added in v1.2.0

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

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

func (TimeEncodingSchemes) SchemeForUnit added in v0.15.0

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

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

type TimestampEncoderMetrics added in v1.2.0

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

TimestampEncoderMetrics contains timestamp encoder metrics.

func (*TimestampEncoderMetrics) IncAnnotationRewritten added in v1.2.0

func (m *TimestampEncoderMetrics) IncAnnotationRewritten()

IncAnnotationRewritten increments annotation rewritten counter.

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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