Documentation
¶
Overview ¶
Package encoding is a generated GoMock package.
Index ¶
- func LeadingAndTrailingZeros(v uint64) (int, int)
- func NumSig(v uint64) uint8
- func SignExtend(v uint64, numBits uint) int64
- func WriteSpecialMarker(os OStream, scheme MarkerEncodingScheme, marker Marker)
- type Bit
- type Decoder
- type Encoder
- type EncoderAllocate
- type EncoderPool
- type IStream
- type IterateEqualTimestampStrategy
- type Iterator
- type IteratorPools
- type Marker
- type MarkerEncodingScheme
- type MockDecoder
- type MockDecoderMockRecorder
- type MockEncoder
- func (m *MockEncoder) Close()
- func (m *MockEncoder) Discard() ts.Segment
- func (m *MockEncoder) DiscardReset(t time.Time, capacity int, schema namespace.SchemaDescr) ts.Segment
- func (m *MockEncoder) EXPECT() *MockEncoderMockRecorder
- func (m *MockEncoder) Encode(dp ts.Datapoint, unit time0.Unit, annotation ts.Annotation) error
- func (m *MockEncoder) LastAnnotationChecksum() (uint64, error)
- func (m *MockEncoder) LastEncoded() (ts.Datapoint, error)
- func (m *MockEncoder) Len() int
- func (m *MockEncoder) NumEncoded() int
- func (m *MockEncoder) Reset(t time.Time, capacity int, schema namespace.SchemaDescr)
- func (m *MockEncoder) SetSchema(descr namespace.SchemaDescr)
- func (m *MockEncoder) Stream(ctx context.Context) (xio.SegmentReader, bool)
- type MockEncoderMockRecorder
- func (mr *MockEncoderMockRecorder) Close() *gomock.Call
- func (mr *MockEncoderMockRecorder) Discard() *gomock.Call
- func (mr *MockEncoderMockRecorder) DiscardReset(t, capacity, schema interface{}) *gomock.Call
- func (mr *MockEncoderMockRecorder) Encode(dp, unit, annotation interface{}) *gomock.Call
- func (mr *MockEncoderMockRecorder) LastAnnotationChecksum() *gomock.Call
- func (mr *MockEncoderMockRecorder) LastEncoded() *gomock.Call
- func (mr *MockEncoderMockRecorder) Len() *gomock.Call
- func (mr *MockEncoderMockRecorder) NumEncoded() *gomock.Call
- func (mr *MockEncoderMockRecorder) Reset(t, capacity, schema interface{}) *gomock.Call
- func (mr *MockEncoderMockRecorder) SetSchema(descr interface{}) *gomock.Call
- func (mr *MockEncoderMockRecorder) Stream(ctx interface{}) *gomock.Call
- type MockEncoderPool
- type MockEncoderPoolMockRecorder
- type MockIStream
- func (m *MockIStream) EXPECT() *MockIStreamMockRecorder
- func (m *MockIStream) PeekBits(numBits uint) (uint64, error)
- func (m *MockIStream) Read(arg0 []byte) (int, error)
- func (m *MockIStream) ReadBit() (Bit, error)
- func (m *MockIStream) ReadBits(numBits uint) (uint64, error)
- func (m *MockIStream) ReadByte() (byte, error)
- func (m *MockIStream) RemainingBitsInCurrentByte() uint
- func (m *MockIStream) Reset(r io.Reader)
- type MockIStreamMockRecorder
- func (mr *MockIStreamMockRecorder) PeekBits(numBits interface{}) *gomock.Call
- func (mr *MockIStreamMockRecorder) Read(arg0 interface{}) *gomock.Call
- func (mr *MockIStreamMockRecorder) ReadBit() *gomock.Call
- func (mr *MockIStreamMockRecorder) ReadBits(numBits interface{}) *gomock.Call
- func (mr *MockIStreamMockRecorder) ReadByte() *gomock.Call
- func (mr *MockIStreamMockRecorder) RemainingBitsInCurrentByte() *gomock.Call
- func (mr *MockIStreamMockRecorder) Reset(r interface{}) *gomock.Call
- type MockIterator
- type MockIteratorMockRecorder
- type MockIteratorPools
- func (m *MockIteratorPools) CheckedBytesWrapper() xpool.CheckedBytesWrapperPool
- func (m *MockIteratorPools) EXPECT() *MockIteratorPoolsMockRecorder
- func (m *MockIteratorPools) ID() ident.Pool
- func (m *MockIteratorPools) MultiReaderIterator() MultiReaderIteratorPool
- func (m *MockIteratorPools) MultiReaderIteratorArray() MultiReaderIteratorArrayPool
- func (m *MockIteratorPools) MutableSeriesIterators() MutableSeriesIteratorsPool
- func (m *MockIteratorPools) SeriesIterator() SeriesIteratorPool
- func (m *MockIteratorPools) TagDecoder() serialize.TagDecoderPool
- func (m *MockIteratorPools) TagEncoder() serialize.TagEncoderPool
- type MockIteratorPoolsMockRecorder
- func (mr *MockIteratorPoolsMockRecorder) CheckedBytesWrapper() *gomock.Call
- func (mr *MockIteratorPoolsMockRecorder) ID() *gomock.Call
- func (mr *MockIteratorPoolsMockRecorder) MultiReaderIterator() *gomock.Call
- func (mr *MockIteratorPoolsMockRecorder) MultiReaderIteratorArray() *gomock.Call
- func (mr *MockIteratorPoolsMockRecorder) MutableSeriesIterators() *gomock.Call
- func (mr *MockIteratorPoolsMockRecorder) SeriesIterator() *gomock.Call
- func (mr *MockIteratorPoolsMockRecorder) TagDecoder() *gomock.Call
- func (mr *MockIteratorPoolsMockRecorder) TagEncoder() *gomock.Call
- type MockMultiReaderIterator
- func (m *MockMultiReaderIterator) Close()
- func (m *MockMultiReaderIterator) Current() (ts.Datapoint, time0.Unit, ts.Annotation)
- func (m *MockMultiReaderIterator) EXPECT() *MockMultiReaderIteratorMockRecorder
- func (m *MockMultiReaderIterator) Err() error
- func (m *MockMultiReaderIterator) Next() bool
- func (m *MockMultiReaderIterator) Readers() xio.ReaderSliceOfSlicesIterator
- func (m *MockMultiReaderIterator) Reset(readers []xio.SegmentReader, start time.Time, blockSize time.Duration, ...)
- func (m *MockMultiReaderIterator) ResetSliceOfSlices(readers xio.ReaderSliceOfSlicesIterator, schema namespace.SchemaDescr)
- func (m *MockMultiReaderIterator) Schema() namespace.SchemaDescr
- type MockMultiReaderIteratorArrayPool
- func (m *MockMultiReaderIteratorArrayPool) EXPECT() *MockMultiReaderIteratorArrayPoolMockRecorder
- func (m *MockMultiReaderIteratorArrayPool) Get(size int) []MultiReaderIterator
- func (m *MockMultiReaderIteratorArrayPool) Init()
- func (m *MockMultiReaderIteratorArrayPool) Put(iters []MultiReaderIterator)
- type MockMultiReaderIteratorArrayPoolMockRecorder
- type MockMultiReaderIteratorMockRecorder
- func (mr *MockMultiReaderIteratorMockRecorder) Close() *gomock.Call
- func (mr *MockMultiReaderIteratorMockRecorder) Current() *gomock.Call
- func (mr *MockMultiReaderIteratorMockRecorder) Err() *gomock.Call
- func (mr *MockMultiReaderIteratorMockRecorder) Next() *gomock.Call
- func (mr *MockMultiReaderIteratorMockRecorder) Readers() *gomock.Call
- func (mr *MockMultiReaderIteratorMockRecorder) Reset(readers, start, blockSize, schema interface{}) *gomock.Call
- func (mr *MockMultiReaderIteratorMockRecorder) ResetSliceOfSlices(readers, schema interface{}) *gomock.Call
- func (mr *MockMultiReaderIteratorMockRecorder) Schema() *gomock.Call
- type MockMultiReaderIteratorPool
- type MockMultiReaderIteratorPoolMockRecorder
- type MockMutableSeriesIterators
- func (m *MockMutableSeriesIterators) Cap() int
- func (m *MockMutableSeriesIterators) Close()
- func (m *MockMutableSeriesIterators) EXPECT() *MockMutableSeriesIteratorsMockRecorder
- func (m *MockMutableSeriesIterators) Iters() []SeriesIterator
- func (m *MockMutableSeriesIterators) Len() int
- func (m *MockMutableSeriesIterators) Reset(size int)
- func (m *MockMutableSeriesIterators) SetAt(idx int, iter SeriesIterator)
- type MockMutableSeriesIteratorsMockRecorder
- func (mr *MockMutableSeriesIteratorsMockRecorder) Cap() *gomock.Call
- func (mr *MockMutableSeriesIteratorsMockRecorder) Close() *gomock.Call
- func (mr *MockMutableSeriesIteratorsMockRecorder) Iters() *gomock.Call
- func (mr *MockMutableSeriesIteratorsMockRecorder) Len() *gomock.Call
- func (mr *MockMutableSeriesIteratorsMockRecorder) Reset(size interface{}) *gomock.Call
- func (mr *MockMutableSeriesIteratorsMockRecorder) SetAt(idx, iter interface{}) *gomock.Call
- type MockMutableSeriesIteratorsPool
- type MockMutableSeriesIteratorsPoolMockRecorder
- type MockOStream
- func (m *MockOStream) CheckedBytes() (checked.Bytes, int)
- func (m *MockOStream) Discard() checked.Bytes
- func (m *MockOStream) EXPECT() *MockOStreamMockRecorder
- func (m *MockOStream) Empty() bool
- func (m *MockOStream) Len() int
- func (m *MockOStream) RawBytes() ([]byte, int)
- func (m *MockOStream) Reset(buffer checked.Bytes)
- func (m *MockOStream) Write(bytes []byte) (int, error)
- func (m *MockOStream) WriteBit(v Bit)
- func (m *MockOStream) WriteBits(v uint64, numBits int)
- func (m *MockOStream) WriteByte(v byte)
- func (m *MockOStream) WriteBytes(bytes []byte)
- type MockOStreamMockRecorder
- func (mr *MockOStreamMockRecorder) CheckedBytes() *gomock.Call
- func (mr *MockOStreamMockRecorder) Discard() *gomock.Call
- func (mr *MockOStreamMockRecorder) Empty() *gomock.Call
- func (mr *MockOStreamMockRecorder) Len() *gomock.Call
- func (mr *MockOStreamMockRecorder) RawBytes() *gomock.Call
- func (mr *MockOStreamMockRecorder) Reset(buffer interface{}) *gomock.Call
- func (mr *MockOStreamMockRecorder) Write(bytes interface{}) *gomock.Call
- func (mr *MockOStreamMockRecorder) WriteBit(v interface{}) *gomock.Call
- func (mr *MockOStreamMockRecorder) WriteBits(v, numBits interface{}) *gomock.Call
- func (mr *MockOStreamMockRecorder) WriteByte(v interface{}) *gomock.Call
- func (mr *MockOStreamMockRecorder) WriteBytes(bytes interface{}) *gomock.Call
- type MockOptions
- func (m *MockOptions) ByteFieldDictionaryLRUSize() int
- func (m *MockOptions) BytesPool() pool.CheckedBytesPool
- func (m *MockOptions) CheckedBytesWrapperPool() xpool.CheckedBytesWrapperPool
- func (m *MockOptions) DefaultTimeUnit() time0.Unit
- func (m *MockOptions) EXPECT() *MockOptionsMockRecorder
- func (m *MockOptions) EncoderPool() EncoderPool
- func (m *MockOptions) IStreamReaderSizeM3TSZ() int
- func (m *MockOptions) IStreamReaderSizeProto() int
- func (m *MockOptions) MarkerEncodingScheme() MarkerEncodingScheme
- func (m *MockOptions) ReaderIteratorPool() ReaderIteratorPool
- func (m *MockOptions) SegmentReaderPool() xio.SegmentReaderPool
- func (m *MockOptions) SetByteFieldDictionaryLRUSize(value int) Options
- func (m *MockOptions) SetBytesPool(value pool.CheckedBytesPool) Options
- func (m *MockOptions) SetCheckedBytesWrapperPool(value xpool.CheckedBytesWrapperPool) Options
- func (m *MockOptions) SetDefaultTimeUnit(tu time0.Unit) Options
- func (m *MockOptions) SetEncoderPool(value EncoderPool) Options
- func (m *MockOptions) SetIStreamReaderSizeM3TSZ(value int) Options
- func (m *MockOptions) SetIStreamReaderSizeProto(value int) Options
- func (m *MockOptions) SetMarkerEncodingScheme(value MarkerEncodingScheme) Options
- func (m *MockOptions) SetReaderIteratorPool(value ReaderIteratorPool) Options
- func (m *MockOptions) SetSegmentReaderPool(value xio.SegmentReaderPool) Options
- func (m *MockOptions) SetTimeEncodingSchemes(value map[time0.Unit]TimeEncodingScheme) Options
- func (m *MockOptions) TimeEncodingSchemes() TimeEncodingSchemes
- type MockOptionsMockRecorder
- func (mr *MockOptionsMockRecorder) ByteFieldDictionaryLRUSize() *gomock.Call
- func (mr *MockOptionsMockRecorder) BytesPool() *gomock.Call
- func (mr *MockOptionsMockRecorder) CheckedBytesWrapperPool() *gomock.Call
- func (mr *MockOptionsMockRecorder) DefaultTimeUnit() *gomock.Call
- func (mr *MockOptionsMockRecorder) EncoderPool() *gomock.Call
- func (mr *MockOptionsMockRecorder) IStreamReaderSizeM3TSZ() *gomock.Call
- func (mr *MockOptionsMockRecorder) IStreamReaderSizeProto() *gomock.Call
- func (mr *MockOptionsMockRecorder) MarkerEncodingScheme() *gomock.Call
- func (mr *MockOptionsMockRecorder) ReaderIteratorPool() *gomock.Call
- func (mr *MockOptionsMockRecorder) SegmentReaderPool() *gomock.Call
- func (mr *MockOptionsMockRecorder) SetByteFieldDictionaryLRUSize(value interface{}) *gomock.Call
- func (mr *MockOptionsMockRecorder) SetBytesPool(value interface{}) *gomock.Call
- func (mr *MockOptionsMockRecorder) SetCheckedBytesWrapperPool(value interface{}) *gomock.Call
- func (mr *MockOptionsMockRecorder) SetDefaultTimeUnit(tu interface{}) *gomock.Call
- func (mr *MockOptionsMockRecorder) SetEncoderPool(value interface{}) *gomock.Call
- func (mr *MockOptionsMockRecorder) SetIStreamReaderSizeM3TSZ(value interface{}) *gomock.Call
- func (mr *MockOptionsMockRecorder) SetIStreamReaderSizeProto(value interface{}) *gomock.Call
- func (mr *MockOptionsMockRecorder) SetMarkerEncodingScheme(value interface{}) *gomock.Call
- func (mr *MockOptionsMockRecorder) SetReaderIteratorPool(value interface{}) *gomock.Call
- func (mr *MockOptionsMockRecorder) SetSegmentReaderPool(value interface{}) *gomock.Call
- func (mr *MockOptionsMockRecorder) SetTimeEncodingSchemes(value interface{}) *gomock.Call
- func (mr *MockOptionsMockRecorder) TimeEncodingSchemes() *gomock.Call
- type MockReaderIterator
- func (m *MockReaderIterator) Close()
- func (m *MockReaderIterator) Current() (ts.Datapoint, time0.Unit, ts.Annotation)
- func (m *MockReaderIterator) EXPECT() *MockReaderIteratorMockRecorder
- func (m *MockReaderIterator) Err() error
- func (m *MockReaderIterator) Next() bool
- func (m *MockReaderIterator) Reset(reader io.Reader, schema namespace.SchemaDescr)
- type MockReaderIteratorMockRecorder
- func (mr *MockReaderIteratorMockRecorder) Close() *gomock.Call
- func (mr *MockReaderIteratorMockRecorder) Current() *gomock.Call
- func (mr *MockReaderIteratorMockRecorder) Err() *gomock.Call
- func (mr *MockReaderIteratorMockRecorder) Next() *gomock.Call
- func (mr *MockReaderIteratorMockRecorder) Reset(reader, schema interface{}) *gomock.Call
- type MockReaderIteratorPool
- type MockReaderIteratorPoolMockRecorder
- type MockSeriesIterator
- func (m *MockSeriesIterator) Close()
- func (m *MockSeriesIterator) Current() (ts.Datapoint, time0.Unit, ts.Annotation)
- func (m *MockSeriesIterator) EXPECT() *MockSeriesIteratorMockRecorder
- func (m *MockSeriesIterator) End() time.Time
- func (m *MockSeriesIterator) Err() error
- func (m *MockSeriesIterator) ID() ident.ID
- func (m *MockSeriesIterator) Namespace() ident.ID
- func (m *MockSeriesIterator) Next() bool
- func (m *MockSeriesIterator) Replicas() ([]MultiReaderIterator, error)
- func (m *MockSeriesIterator) Reset(opts SeriesIteratorOptions)
- func (m *MockSeriesIterator) SetIterateEqualTimestampStrategy(strategy IterateEqualTimestampStrategy)
- func (m *MockSeriesIterator) Start() time.Time
- func (m *MockSeriesIterator) Stats() (SeriesIteratorStats, error)
- func (m *MockSeriesIterator) Tags() ident.TagIterator
- type MockSeriesIteratorAccumulator
- func (m *MockSeriesIteratorAccumulator) Add(it SeriesIterator) error
- func (m *MockSeriesIteratorAccumulator) Close()
- func (m *MockSeriesIteratorAccumulator) Current() (ts.Datapoint, time0.Unit, ts.Annotation)
- func (m *MockSeriesIteratorAccumulator) EXPECT() *MockSeriesIteratorAccumulatorMockRecorder
- func (m *MockSeriesIteratorAccumulator) End() time.Time
- func (m *MockSeriesIteratorAccumulator) Err() error
- func (m *MockSeriesIteratorAccumulator) ID() ident.ID
- func (m *MockSeriesIteratorAccumulator) Namespace() ident.ID
- func (m *MockSeriesIteratorAccumulator) Next() bool
- func (m *MockSeriesIteratorAccumulator) Replicas() ([]MultiReaderIterator, error)
- func (m *MockSeriesIteratorAccumulator) Reset(opts SeriesIteratorOptions)
- func (m *MockSeriesIteratorAccumulator) SetIterateEqualTimestampStrategy(strategy IterateEqualTimestampStrategy)
- func (m *MockSeriesIteratorAccumulator) Start() time.Time
- func (m *MockSeriesIteratorAccumulator) Stats() (SeriesIteratorStats, error)
- func (m *MockSeriesIteratorAccumulator) Tags() ident.TagIterator
- type MockSeriesIteratorAccumulatorMockRecorder
- func (mr *MockSeriesIteratorAccumulatorMockRecorder) Add(it interface{}) *gomock.Call
- func (mr *MockSeriesIteratorAccumulatorMockRecorder) Close() *gomock.Call
- func (mr *MockSeriesIteratorAccumulatorMockRecorder) Current() *gomock.Call
- func (mr *MockSeriesIteratorAccumulatorMockRecorder) End() *gomock.Call
- func (mr *MockSeriesIteratorAccumulatorMockRecorder) Err() *gomock.Call
- func (mr *MockSeriesIteratorAccumulatorMockRecorder) ID() *gomock.Call
- func (mr *MockSeriesIteratorAccumulatorMockRecorder) Namespace() *gomock.Call
- func (mr *MockSeriesIteratorAccumulatorMockRecorder) Next() *gomock.Call
- func (mr *MockSeriesIteratorAccumulatorMockRecorder) Replicas() *gomock.Call
- func (mr *MockSeriesIteratorAccumulatorMockRecorder) Reset(opts interface{}) *gomock.Call
- func (mr *MockSeriesIteratorAccumulatorMockRecorder) SetIterateEqualTimestampStrategy(strategy interface{}) *gomock.Call
- func (mr *MockSeriesIteratorAccumulatorMockRecorder) Start() *gomock.Call
- func (mr *MockSeriesIteratorAccumulatorMockRecorder) Stats() *gomock.Call
- func (mr *MockSeriesIteratorAccumulatorMockRecorder) Tags() *gomock.Call
- type MockSeriesIteratorConsolidator
- type MockSeriesIteratorConsolidatorMockRecorder
- type MockSeriesIteratorMockRecorder
- func (mr *MockSeriesIteratorMockRecorder) Close() *gomock.Call
- func (mr *MockSeriesIteratorMockRecorder) Current() *gomock.Call
- func (mr *MockSeriesIteratorMockRecorder) End() *gomock.Call
- func (mr *MockSeriesIteratorMockRecorder) Err() *gomock.Call
- func (mr *MockSeriesIteratorMockRecorder) ID() *gomock.Call
- func (mr *MockSeriesIteratorMockRecorder) Namespace() *gomock.Call
- func (mr *MockSeriesIteratorMockRecorder) Next() *gomock.Call
- func (mr *MockSeriesIteratorMockRecorder) Replicas() *gomock.Call
- func (mr *MockSeriesIteratorMockRecorder) Reset(opts interface{}) *gomock.Call
- func (mr *MockSeriesIteratorMockRecorder) SetIterateEqualTimestampStrategy(strategy interface{}) *gomock.Call
- func (mr *MockSeriesIteratorMockRecorder) Start() *gomock.Call
- func (mr *MockSeriesIteratorMockRecorder) Stats() *gomock.Call
- func (mr *MockSeriesIteratorMockRecorder) Tags() *gomock.Call
- type MockSeriesIteratorPool
- type MockSeriesIteratorPoolMockRecorder
- type MockSeriesIterators
- type MockSeriesIteratorsMockRecorder
- type MultiReaderIterator
- type MultiReaderIteratorArrayPool
- type MultiReaderIteratorPool
- type MutableSeriesIterators
- type MutableSeriesIteratorsPool
- type NewDecoderFn
- type NewEncoderFn
- type OStream
- type Options
- type ReaderIterator
- type ReaderIteratorAllocate
- type ReaderIteratorPool
- type SeriesAccumulatorOptions
- type SeriesIterator
- type SeriesIteratorAccumulator
- type SeriesIteratorConsolidator
- type SeriesIteratorOptions
- type SeriesIteratorPool
- type SeriesIteratorStats
- type SeriesIterators
- type TimeBucket
- type TimeEncodingScheme
- type TimeEncodingSchemes
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func LeadingAndTrailingZeros ¶
LeadingAndTrailingZeros calculates the number of leading and trailing 0s for a uint64.
func SignExtend ¶
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 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.
type IterateEqualTimestampStrategy ¶ added in v0.4.4
type IterateEqualTimestampStrategy uint8
IterateEqualTimestampStrategy describes the strategy of which value to select when values with equal timestamps appear in the list of iterators.
const ( // IterateLastPushed is useful for within a single replica, using the last // immutable buffer that was created to decide which value to choose. It is // important to order the buffers passed to the construction of the iterators // in the correct order to achieve the desired outcome. IterateLastPushed IterateEqualTimestampStrategy = iota // IterateHighestValue is useful across replicas when you just want to choose // the highest value every time. IterateHighestValue // IterateLowestValue is useful across replicas when you just want to choose // the lowest value every time. IterateLowestValue // IterateHighestFrequencyValue is useful across replicas when you want to // choose the most common appearing value, however you can only use this // reliably if you wait for values from all replicas to be retrieved, i.e. // you cannot use this reliably with quorum/majority consistency. IterateHighestFrequencyValue // DefaultIterateEqualTimestampStrategy is the default iterate // equal timestamp strategy. DefaultIterateEqualTimestampStrategy = IterateLastPushed )
func ParseIterateEqualTimestampStrategy ¶ added in v0.4.4
func ParseIterateEqualTimestampStrategy( str string, ) (IterateEqualTimestampStrategy, error)
ParseIterateEqualTimestampStrategy parses a IterateEqualTimestampStrategy from a string.
func ValidIterateEqualTimestampStrategies ¶ added in v0.4.4
func ValidIterateEqualTimestampStrategies() []IterateEqualTimestampStrategy
ValidIterateEqualTimestampStrategies returns the valid iterate equal timestamp strategies.
func (IterateEqualTimestampStrategy) String ¶ added in v0.4.4
func (s IterateEqualTimestampStrategy) String() string
func (*IterateEqualTimestampStrategy) UnmarshalYAML ¶ added in v0.4.4
func (s *IterateEqualTimestampStrategy) UnmarshalYAML(unmarshal func(interface{}) error) error
UnmarshalYAML unmarshals an IterateEqualTimestampStrategy into a valid type from string.
type Iterator ¶
type Iterator interface { // Next moves to the next item. Next() bool // Current returns the value as well as the annotation associated with the // current datapoint. Users should not hold on to the returned Annotation // object as it may get invalidated when the iterator calls Next(). Current() (ts.Datapoint, xtime.Unit, ts.Annotation) // Err returns the error encountered Err() error // Close closes the iterator and if pooled will return to the pool. Close() }
Iterator is the generic interface for iterating over encoded data.
type IteratorPools ¶
type IteratorPools interface { // MultiReaderIteratorArray exposes the session MultiReaderIteratorArrayPool. MultiReaderIteratorArray() MultiReaderIteratorArrayPool // MultiReaderIterator exposes the session MultiReaderIteratorPool. MultiReaderIterator() MultiReaderIteratorPool // MutableSeriesIterators exposes the session MutableSeriesIteratorsPool. MutableSeriesIterators() MutableSeriesIteratorsPool // SeriesIterator exposes the session SeriesIteratorPool. SeriesIterator() SeriesIteratorPool // CheckedBytesWrapper exposes the session CheckedBytesWrapperPool. CheckedBytesWrapper() xpool.CheckedBytesWrapperPool // ID exposes the session identity pool. ID() ident.Pool // TagEncoder exposes the session tag encoder pool. TagEncoder() serialize.TagEncoderPool // TagDecoder exposes the session tag decoder pool. TagDecoder() serialize.TagDecoderPool }
IteratorPools exposes a small subset of iterator pools that are sufficient for clients to rebuild SeriesIterator.
type 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) 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) 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 ¶
func (m *MockEncoderPool) EXPECT() *MockEncoderPoolMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockEncoderPool) Init ¶
func (m *MockEncoderPool) Init(alloc EncoderAllocate)
Init mocks base method
type MockEncoderPoolMockRecorder ¶
type MockEncoderPoolMockRecorder struct {
// contains filtered or unexported fields
}
MockEncoderPoolMockRecorder is the mock recorder for MockEncoderPool
func (*MockEncoderPoolMockRecorder) Get ¶
func (mr *MockEncoderPoolMockRecorder) Get() *gomock.Call
Get indicates an expected call of Get
func (*MockEncoderPoolMockRecorder) Init ¶
func (mr *MockEncoderPoolMockRecorder) Init(alloc interface{}) *gomock.Call
Init indicates an expected call of Init
func (*MockEncoderPoolMockRecorder) Put ¶
func (mr *MockEncoderPoolMockRecorder) Put(e interface{}) *gomock.Call
Put indicates an expected call of Put
type MockIStream ¶
type MockIStream struct {
// contains filtered or unexported fields
}
MockIStream is a mock of IStream interface
func NewMockIStream ¶
func NewMockIStream(ctrl *gomock.Controller) *MockIStream
NewMockIStream creates a new mock instance
func (*MockIStream) EXPECT ¶
func (m *MockIStream) EXPECT() *MockIStreamMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockIStream) PeekBits ¶
func (m *MockIStream) PeekBits(numBits uint) (uint64, error)
PeekBits mocks base method
func (*MockIStream) Read ¶ added in v0.8.2
func (m *MockIStream) Read(arg0 []byte) (int, error)
Read mocks base method
func (*MockIStream) ReadBit ¶
func (m *MockIStream) ReadBit() (Bit, error)
ReadBit mocks base method
func (*MockIStream) ReadBits ¶
func (m *MockIStream) ReadBits(numBits uint) (uint64, error)
ReadBits mocks base method
func (*MockIStream) ReadByte ¶
func (m *MockIStream) ReadByte() (byte, error)
ReadByte mocks base method
func (*MockIStream) RemainingBitsInCurrentByte ¶ added in v0.8.2
func (m *MockIStream) RemainingBitsInCurrentByte() uint
RemainingBitsInCurrentByte mocks base method
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) Current ¶
func (m *MockIterator) Current() (ts.Datapoint, time0.Unit, ts.Annotation)
Current mocks base method
func (*MockIterator) EXPECT ¶
func (m *MockIterator) EXPECT() *MockIteratorMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
type MockIteratorMockRecorder ¶
type MockIteratorMockRecorder struct {
// contains filtered or unexported fields
}
MockIteratorMockRecorder is the mock recorder for MockIterator
func (*MockIteratorMockRecorder) Close ¶
func (mr *MockIteratorMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close
func (*MockIteratorMockRecorder) Current ¶
func (mr *MockIteratorMockRecorder) Current() *gomock.Call
Current indicates an expected call of Current
func (*MockIteratorMockRecorder) Err ¶
func (mr *MockIteratorMockRecorder) Err() *gomock.Call
Err indicates an expected call of Err
func (*MockIteratorMockRecorder) Next ¶
func (mr *MockIteratorMockRecorder) Next() *gomock.Call
Next indicates an expected call of Next
type MockIteratorPools ¶
type MockIteratorPools struct {
// contains filtered or unexported fields
}
MockIteratorPools is a mock of IteratorPools interface
func NewMockIteratorPools ¶
func NewMockIteratorPools(ctrl *gomock.Controller) *MockIteratorPools
NewMockIteratorPools creates a new mock instance
func (*MockIteratorPools) CheckedBytesWrapper ¶
func (m *MockIteratorPools) CheckedBytesWrapper() xpool.CheckedBytesWrapperPool
CheckedBytesWrapper mocks base method
func (*MockIteratorPools) EXPECT ¶
func (m *MockIteratorPools) EXPECT() *MockIteratorPoolsMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockIteratorPools) MultiReaderIterator ¶
func (m *MockIteratorPools) MultiReaderIterator() MultiReaderIteratorPool
MultiReaderIterator mocks base method
func (*MockIteratorPools) MultiReaderIteratorArray ¶
func (m *MockIteratorPools) MultiReaderIteratorArray() MultiReaderIteratorArrayPool
MultiReaderIteratorArray mocks base method
func (*MockIteratorPools) MutableSeriesIterators ¶ added in v0.3.0
func (m *MockIteratorPools) MutableSeriesIterators() MutableSeriesIteratorsPool
MutableSeriesIterators mocks base method
func (*MockIteratorPools) SeriesIterator ¶
func (m *MockIteratorPools) SeriesIterator() SeriesIteratorPool
SeriesIterator mocks base method
func (*MockIteratorPools) TagDecoder ¶ added in v0.3.0
func (m *MockIteratorPools) TagDecoder() serialize.TagDecoderPool
TagDecoder mocks base method
func (*MockIteratorPools) TagEncoder ¶ added in v0.3.0
func (m *MockIteratorPools) TagEncoder() serialize.TagEncoderPool
TagEncoder mocks base method
type MockIteratorPoolsMockRecorder ¶
type MockIteratorPoolsMockRecorder struct {
// contains filtered or unexported fields
}
MockIteratorPoolsMockRecorder is the mock recorder for MockIteratorPools
func (*MockIteratorPoolsMockRecorder) CheckedBytesWrapper ¶
func (mr *MockIteratorPoolsMockRecorder) CheckedBytesWrapper() *gomock.Call
CheckedBytesWrapper indicates an expected call of CheckedBytesWrapper
func (*MockIteratorPoolsMockRecorder) ID ¶
func (mr *MockIteratorPoolsMockRecorder) ID() *gomock.Call
ID indicates an expected call of ID
func (*MockIteratorPoolsMockRecorder) MultiReaderIterator ¶
func (mr *MockIteratorPoolsMockRecorder) MultiReaderIterator() *gomock.Call
MultiReaderIterator indicates an expected call of MultiReaderIterator
func (*MockIteratorPoolsMockRecorder) MultiReaderIteratorArray ¶
func (mr *MockIteratorPoolsMockRecorder) MultiReaderIteratorArray() *gomock.Call
MultiReaderIteratorArray indicates an expected call of MultiReaderIteratorArray
func (*MockIteratorPoolsMockRecorder) MutableSeriesIterators ¶ added in v0.3.0
func (mr *MockIteratorPoolsMockRecorder) MutableSeriesIterators() *gomock.Call
MutableSeriesIterators indicates an expected call of MutableSeriesIterators
func (*MockIteratorPoolsMockRecorder) SeriesIterator ¶
func (mr *MockIteratorPoolsMockRecorder) SeriesIterator() *gomock.Call
SeriesIterator indicates an expected call of SeriesIterator
func (*MockIteratorPoolsMockRecorder) TagDecoder ¶ added in v0.3.0
func (mr *MockIteratorPoolsMockRecorder) TagDecoder() *gomock.Call
TagDecoder indicates an expected call of TagDecoder
func (*MockIteratorPoolsMockRecorder) TagEncoder ¶ added in v0.3.0
func (mr *MockIteratorPoolsMockRecorder) TagEncoder() *gomock.Call
TagEncoder indicates an expected call of TagEncoder
type MockMultiReaderIterator ¶
type MockMultiReaderIterator struct {
// contains filtered or unexported fields
}
MockMultiReaderIterator is a mock of MultiReaderIterator interface
func NewMockMultiReaderIterator ¶
func NewMockMultiReaderIterator(ctrl *gomock.Controller) *MockMultiReaderIterator
NewMockMultiReaderIterator creates a new mock instance
func (*MockMultiReaderIterator) Close ¶
func (m *MockMultiReaderIterator) Close()
Close mocks base method
func (*MockMultiReaderIterator) Current ¶
func (m *MockMultiReaderIterator) Current() (ts.Datapoint, time0.Unit, ts.Annotation)
Current mocks base method
func (*MockMultiReaderIterator) EXPECT ¶
func (m *MockMultiReaderIterator) EXPECT() *MockMultiReaderIteratorMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockMultiReaderIterator) Err ¶
func (m *MockMultiReaderIterator) Err() error
Err mocks base method
func (*MockMultiReaderIterator) Next ¶
func (m *MockMultiReaderIterator) Next() bool
Next mocks base method
func (*MockMultiReaderIterator) Readers ¶
func (m *MockMultiReaderIterator) Readers() xio.ReaderSliceOfSlicesIterator
Readers mocks base method
func (*MockMultiReaderIterator) Reset ¶
func (m *MockMultiReaderIterator) Reset(readers []xio.SegmentReader, start time.Time, blockSize time.Duration, schema namespace.SchemaDescr)
Reset mocks base method
func (*MockMultiReaderIterator) ResetSliceOfSlices ¶
func (m *MockMultiReaderIterator) ResetSliceOfSlices(readers xio.ReaderSliceOfSlicesIterator, schema namespace.SchemaDescr)
ResetSliceOfSlices mocks base method
func (*MockMultiReaderIterator) Schema ¶ added in v0.15.0
func (m *MockMultiReaderIterator) Schema() namespace.SchemaDescr
Schema mocks base method
type MockMultiReaderIteratorArrayPool ¶
type MockMultiReaderIteratorArrayPool struct {
// contains filtered or unexported fields
}
MockMultiReaderIteratorArrayPool is a mock of MultiReaderIteratorArrayPool interface
func NewMockMultiReaderIteratorArrayPool ¶
func NewMockMultiReaderIteratorArrayPool(ctrl *gomock.Controller) *MockMultiReaderIteratorArrayPool
NewMockMultiReaderIteratorArrayPool creates a new mock instance
func (*MockMultiReaderIteratorArrayPool) EXPECT ¶
func (m *MockMultiReaderIteratorArrayPool) EXPECT() *MockMultiReaderIteratorArrayPoolMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockMultiReaderIteratorArrayPool) Get ¶
func (m *MockMultiReaderIteratorArrayPool) Get(size int) []MultiReaderIterator
Get mocks base method
func (*MockMultiReaderIteratorArrayPool) Init ¶
func (m *MockMultiReaderIteratorArrayPool) Init()
Init mocks base method
func (*MockMultiReaderIteratorArrayPool) Put ¶
func (m *MockMultiReaderIteratorArrayPool) Put(iters []MultiReaderIterator)
Put mocks base method
type MockMultiReaderIteratorArrayPoolMockRecorder ¶
type MockMultiReaderIteratorArrayPoolMockRecorder struct {
// contains filtered or unexported fields
}
MockMultiReaderIteratorArrayPoolMockRecorder is the mock recorder for MockMultiReaderIteratorArrayPool
func (*MockMultiReaderIteratorArrayPoolMockRecorder) Get ¶
func (mr *MockMultiReaderIteratorArrayPoolMockRecorder) Get(size interface{}) *gomock.Call
Get indicates an expected call of Get
func (*MockMultiReaderIteratorArrayPoolMockRecorder) Init ¶
func (mr *MockMultiReaderIteratorArrayPoolMockRecorder) Init() *gomock.Call
Init indicates an expected call of Init
func (*MockMultiReaderIteratorArrayPoolMockRecorder) Put ¶
func (mr *MockMultiReaderIteratorArrayPoolMockRecorder) Put(iters interface{}) *gomock.Call
Put indicates an expected call of Put
type MockMultiReaderIteratorMockRecorder ¶
type MockMultiReaderIteratorMockRecorder struct {
// contains filtered or unexported fields
}
MockMultiReaderIteratorMockRecorder is the mock recorder for MockMultiReaderIterator
func (*MockMultiReaderIteratorMockRecorder) Close ¶
func (mr *MockMultiReaderIteratorMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close
func (*MockMultiReaderIteratorMockRecorder) Current ¶
func (mr *MockMultiReaderIteratorMockRecorder) Current() *gomock.Call
Current indicates an expected call of Current
func (*MockMultiReaderIteratorMockRecorder) Err ¶
func (mr *MockMultiReaderIteratorMockRecorder) Err() *gomock.Call
Err indicates an expected call of Err
func (*MockMultiReaderIteratorMockRecorder) Next ¶
func (mr *MockMultiReaderIteratorMockRecorder) Next() *gomock.Call
Next indicates an expected call of Next
func (*MockMultiReaderIteratorMockRecorder) Readers ¶
func (mr *MockMultiReaderIteratorMockRecorder) Readers() *gomock.Call
Readers indicates an expected call of Readers
func (*MockMultiReaderIteratorMockRecorder) Reset ¶
func (mr *MockMultiReaderIteratorMockRecorder) Reset(readers, start, blockSize, schema interface{}) *gomock.Call
Reset indicates an expected call of Reset
func (*MockMultiReaderIteratorMockRecorder) ResetSliceOfSlices ¶
func (mr *MockMultiReaderIteratorMockRecorder) ResetSliceOfSlices(readers, schema interface{}) *gomock.Call
ResetSliceOfSlices indicates an expected call of ResetSliceOfSlices
func (*MockMultiReaderIteratorMockRecorder) Schema ¶ added in v0.15.0
func (mr *MockMultiReaderIteratorMockRecorder) Schema() *gomock.Call
Schema indicates an expected call of Schema
type MockMultiReaderIteratorPool ¶
type MockMultiReaderIteratorPool struct {
// contains filtered or unexported fields
}
MockMultiReaderIteratorPool is a mock of MultiReaderIteratorPool interface
func NewMockMultiReaderIteratorPool ¶
func NewMockMultiReaderIteratorPool(ctrl *gomock.Controller) *MockMultiReaderIteratorPool
NewMockMultiReaderIteratorPool creates a new mock instance
func (*MockMultiReaderIteratorPool) EXPECT ¶
func (m *MockMultiReaderIteratorPool) EXPECT() *MockMultiReaderIteratorPoolMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockMultiReaderIteratorPool) Get ¶
func (m *MockMultiReaderIteratorPool) Get() MultiReaderIterator
Get mocks base method
func (*MockMultiReaderIteratorPool) Init ¶
func (m *MockMultiReaderIteratorPool) Init(alloc ReaderIteratorAllocate)
Init mocks base method
func (*MockMultiReaderIteratorPool) Put ¶
func (m *MockMultiReaderIteratorPool) Put(iter MultiReaderIterator)
Put mocks base method
type MockMultiReaderIteratorPoolMockRecorder ¶
type MockMultiReaderIteratorPoolMockRecorder struct {
// contains filtered or unexported fields
}
MockMultiReaderIteratorPoolMockRecorder is the mock recorder for MockMultiReaderIteratorPool
func (*MockMultiReaderIteratorPoolMockRecorder) Get ¶
func (mr *MockMultiReaderIteratorPoolMockRecorder) Get() *gomock.Call
Get indicates an expected call of Get
func (*MockMultiReaderIteratorPoolMockRecorder) Init ¶
func (mr *MockMultiReaderIteratorPoolMockRecorder) Init(alloc interface{}) *gomock.Call
Init indicates an expected call of Init
func (*MockMultiReaderIteratorPoolMockRecorder) Put ¶
func (mr *MockMultiReaderIteratorPoolMockRecorder) Put(iter interface{}) *gomock.Call
Put indicates an expected call of Put
type MockMutableSeriesIterators ¶
type MockMutableSeriesIterators struct {
// contains filtered or unexported fields
}
MockMutableSeriesIterators is a mock of MutableSeriesIterators interface
func NewMockMutableSeriesIterators ¶
func NewMockMutableSeriesIterators(ctrl *gomock.Controller) *MockMutableSeriesIterators
NewMockMutableSeriesIterators creates a new mock instance
func (*MockMutableSeriesIterators) Cap ¶
func (m *MockMutableSeriesIterators) Cap() int
Cap mocks base method
func (*MockMutableSeriesIterators) Close ¶
func (m *MockMutableSeriesIterators) Close()
Close mocks base method
func (*MockMutableSeriesIterators) EXPECT ¶
func (m *MockMutableSeriesIterators) EXPECT() *MockMutableSeriesIteratorsMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockMutableSeriesIterators) Iters ¶
func (m *MockMutableSeriesIterators) Iters() []SeriesIterator
Iters mocks base method
func (*MockMutableSeriesIterators) Len ¶
func (m *MockMutableSeriesIterators) Len() int
Len mocks base method
func (*MockMutableSeriesIterators) Reset ¶
func (m *MockMutableSeriesIterators) Reset(size int)
Reset mocks base method
func (*MockMutableSeriesIterators) SetAt ¶
func (m *MockMutableSeriesIterators) SetAt(idx int, iter SeriesIterator)
SetAt mocks base method
type MockMutableSeriesIteratorsMockRecorder ¶
type MockMutableSeriesIteratorsMockRecorder struct {
// contains filtered or unexported fields
}
MockMutableSeriesIteratorsMockRecorder is the mock recorder for MockMutableSeriesIterators
func (*MockMutableSeriesIteratorsMockRecorder) Cap ¶
func (mr *MockMutableSeriesIteratorsMockRecorder) Cap() *gomock.Call
Cap indicates an expected call of Cap
func (*MockMutableSeriesIteratorsMockRecorder) Close ¶
func (mr *MockMutableSeriesIteratorsMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close
func (*MockMutableSeriesIteratorsMockRecorder) Iters ¶
func (mr *MockMutableSeriesIteratorsMockRecorder) Iters() *gomock.Call
Iters indicates an expected call of Iters
func (*MockMutableSeriesIteratorsMockRecorder) Len ¶
func (mr *MockMutableSeriesIteratorsMockRecorder) Len() *gomock.Call
Len indicates an expected call of Len
func (*MockMutableSeriesIteratorsMockRecorder) Reset ¶
func (mr *MockMutableSeriesIteratorsMockRecorder) Reset(size interface{}) *gomock.Call
Reset indicates an expected call of Reset
func (*MockMutableSeriesIteratorsMockRecorder) SetAt ¶
func (mr *MockMutableSeriesIteratorsMockRecorder) SetAt(idx, iter interface{}) *gomock.Call
SetAt indicates an expected call of SetAt
type MockMutableSeriesIteratorsPool ¶
type MockMutableSeriesIteratorsPool struct {
// contains filtered or unexported fields
}
MockMutableSeriesIteratorsPool is a mock of MutableSeriesIteratorsPool interface
func NewMockMutableSeriesIteratorsPool ¶
func NewMockMutableSeriesIteratorsPool(ctrl *gomock.Controller) *MockMutableSeriesIteratorsPool
NewMockMutableSeriesIteratorsPool creates a new mock instance
func (*MockMutableSeriesIteratorsPool) EXPECT ¶
func (m *MockMutableSeriesIteratorsPool) EXPECT() *MockMutableSeriesIteratorsPoolMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockMutableSeriesIteratorsPool) Get ¶
func (m *MockMutableSeriesIteratorsPool) Get(size int) MutableSeriesIterators
Get mocks base method
func (*MockMutableSeriesIteratorsPool) Init ¶
func (m *MockMutableSeriesIteratorsPool) Init()
Init mocks base method
func (*MockMutableSeriesIteratorsPool) Put ¶
func (m *MockMutableSeriesIteratorsPool) Put(iters MutableSeriesIterators)
Put mocks base method
type MockMutableSeriesIteratorsPoolMockRecorder ¶
type MockMutableSeriesIteratorsPoolMockRecorder struct {
// contains filtered or unexported fields
}
MockMutableSeriesIteratorsPoolMockRecorder is the mock recorder for MockMutableSeriesIteratorsPool
func (*MockMutableSeriesIteratorsPoolMockRecorder) Get ¶
func (mr *MockMutableSeriesIteratorsPoolMockRecorder) Get(size interface{}) *gomock.Call
Get indicates an expected call of Get
func (*MockMutableSeriesIteratorsPoolMockRecorder) Init ¶
func (mr *MockMutableSeriesIteratorsPoolMockRecorder) Init() *gomock.Call
Init indicates an expected call of Init
func (*MockMutableSeriesIteratorsPoolMockRecorder) Put ¶
func (mr *MockMutableSeriesIteratorsPoolMockRecorder) Put(iters interface{}) *gomock.Call
Put indicates an expected call of Put
type MockOStream ¶
type MockOStream struct {
// contains filtered or unexported fields
}
MockOStream is a mock of OStream interface
func NewMockOStream ¶
func NewMockOStream(ctrl *gomock.Controller) *MockOStream
NewMockOStream creates a new mock instance
func (*MockOStream) CheckedBytes ¶ added in v0.15.0
func (m *MockOStream) CheckedBytes() (checked.Bytes, int)
CheckedBytes mocks base method
func (*MockOStream) Discard ¶
func (m *MockOStream) Discard() checked.Bytes
Discard mocks base method
func (*MockOStream) EXPECT ¶
func (m *MockOStream) EXPECT() *MockOStreamMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockOStream) 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) WriteBits ¶
func (m *MockOStream) WriteBits(v uint64, numBits int)
WriteBits 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) Current ¶
func (m *MockReaderIterator) Current() (ts.Datapoint, time0.Unit, ts.Annotation)
Current mocks base method
func (*MockReaderIterator) EXPECT ¶
func (m *MockReaderIterator) EXPECT() *MockReaderIteratorMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockReaderIterator) Reset ¶
func (m *MockReaderIterator) Reset(reader io.Reader, schema namespace.SchemaDescr)
Reset mocks base method
type MockReaderIteratorMockRecorder ¶
type MockReaderIteratorMockRecorder struct {
// contains filtered or unexported fields
}
MockReaderIteratorMockRecorder is the mock recorder for MockReaderIterator
func (*MockReaderIteratorMockRecorder) Close ¶
func (mr *MockReaderIteratorMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close
func (*MockReaderIteratorMockRecorder) Current ¶
func (mr *MockReaderIteratorMockRecorder) Current() *gomock.Call
Current indicates an expected call of Current
func (*MockReaderIteratorMockRecorder) Err ¶
func (mr *MockReaderIteratorMockRecorder) Err() *gomock.Call
Err indicates an expected call of Err
func (*MockReaderIteratorMockRecorder) Next ¶
func (mr *MockReaderIteratorMockRecorder) Next() *gomock.Call
Next indicates an expected call of Next
func (*MockReaderIteratorMockRecorder) Reset ¶
func (mr *MockReaderIteratorMockRecorder) Reset(reader, schema interface{}) *gomock.Call
Reset indicates an expected call of Reset
type MockReaderIteratorPool ¶
type MockReaderIteratorPool struct {
// contains filtered or unexported fields
}
MockReaderIteratorPool is a mock of ReaderIteratorPool interface
func NewMockReaderIteratorPool ¶
func NewMockReaderIteratorPool(ctrl *gomock.Controller) *MockReaderIteratorPool
NewMockReaderIteratorPool creates a new mock instance
func (*MockReaderIteratorPool) EXPECT ¶
func (m *MockReaderIteratorPool) EXPECT() *MockReaderIteratorPoolMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockReaderIteratorPool) Get ¶
func (m *MockReaderIteratorPool) Get() ReaderIterator
Get mocks base method
func (*MockReaderIteratorPool) Init ¶
func (m *MockReaderIteratorPool) Init(alloc ReaderIteratorAllocate)
Init mocks base method
func (*MockReaderIteratorPool) Put ¶
func (m *MockReaderIteratorPool) Put(iter ReaderIterator)
Put mocks base method
type MockReaderIteratorPoolMockRecorder ¶
type MockReaderIteratorPoolMockRecorder struct {
// contains filtered or unexported fields
}
MockReaderIteratorPoolMockRecorder is the mock recorder for MockReaderIteratorPool
func (*MockReaderIteratorPoolMockRecorder) Get ¶
func (mr *MockReaderIteratorPoolMockRecorder) Get() *gomock.Call
Get indicates an expected call of Get
func (*MockReaderIteratorPoolMockRecorder) Init ¶
func (mr *MockReaderIteratorPoolMockRecorder) Init(alloc interface{}) *gomock.Call
Init indicates an expected call of Init
func (*MockReaderIteratorPoolMockRecorder) Put ¶
func (mr *MockReaderIteratorPoolMockRecorder) Put(iter interface{}) *gomock.Call
Put indicates an expected call of Put
type MockSeriesIterator ¶
type MockSeriesIterator struct {
// contains filtered or unexported fields
}
MockSeriesIterator is a mock of SeriesIterator interface
func NewMockSeriesIterator ¶
func NewMockSeriesIterator(ctrl *gomock.Controller) *MockSeriesIterator
NewMockSeriesIterator creates a new mock instance
func (*MockSeriesIterator) Current ¶
func (m *MockSeriesIterator) Current() (ts.Datapoint, time0.Unit, ts.Annotation)
Current mocks base method
func (*MockSeriesIterator) EXPECT ¶
func (m *MockSeriesIterator) EXPECT() *MockSeriesIteratorMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockSeriesIterator) Namespace ¶
func (m *MockSeriesIterator) Namespace() ident.ID
Namespace mocks base method
func (*MockSeriesIterator) Replicas ¶
func (m *MockSeriesIterator) Replicas() ([]MultiReaderIterator, error)
Replicas mocks base method
func (*MockSeriesIterator) Reset ¶
func (m *MockSeriesIterator) Reset(opts SeriesIteratorOptions)
Reset mocks base method
func (*MockSeriesIterator) SetIterateEqualTimestampStrategy ¶ added in v0.4.4
func (m *MockSeriesIterator) SetIterateEqualTimestampStrategy(strategy IterateEqualTimestampStrategy)
SetIterateEqualTimestampStrategy mocks base method
func (*MockSeriesIterator) Start ¶
func (m *MockSeriesIterator) Start() time.Time
Start mocks base method
func (*MockSeriesIterator) Stats ¶ added in v0.15.0
func (m *MockSeriesIterator) Stats() (SeriesIteratorStats, error)
Stats mocks base method
func (*MockSeriesIterator) Tags ¶
func (m *MockSeriesIterator) Tags() ident.TagIterator
Tags mocks base method
type MockSeriesIteratorAccumulator ¶ added in v0.15.2
type MockSeriesIteratorAccumulator struct {
// contains filtered or unexported fields
}
MockSeriesIteratorAccumulator is a mock of SeriesIteratorAccumulator interface
func NewMockSeriesIteratorAccumulator ¶ added in v0.15.2
func NewMockSeriesIteratorAccumulator(ctrl *gomock.Controller) *MockSeriesIteratorAccumulator
NewMockSeriesIteratorAccumulator creates a new mock instance
func (*MockSeriesIteratorAccumulator) Add ¶ added in v0.15.2
func (m *MockSeriesIteratorAccumulator) Add(it SeriesIterator) error
Add mocks base method
func (*MockSeriesIteratorAccumulator) Close ¶ added in v0.15.2
func (m *MockSeriesIteratorAccumulator) Close()
Close mocks base method
func (*MockSeriesIteratorAccumulator) Current ¶ added in v0.15.2
func (m *MockSeriesIteratorAccumulator) Current() (ts.Datapoint, time0.Unit, ts.Annotation)
Current mocks base method
func (*MockSeriesIteratorAccumulator) EXPECT ¶ added in v0.15.2
func (m *MockSeriesIteratorAccumulator) EXPECT() *MockSeriesIteratorAccumulatorMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockSeriesIteratorAccumulator) End ¶ added in v0.15.2
func (m *MockSeriesIteratorAccumulator) End() time.Time
End mocks base method
func (*MockSeriesIteratorAccumulator) Err ¶ added in v0.15.2
func (m *MockSeriesIteratorAccumulator) Err() error
Err mocks base method
func (*MockSeriesIteratorAccumulator) ID ¶ added in v0.15.2
func (m *MockSeriesIteratorAccumulator) ID() ident.ID
ID mocks base method
func (*MockSeriesIteratorAccumulator) Namespace ¶ added in v0.15.2
func (m *MockSeriesIteratorAccumulator) Namespace() ident.ID
Namespace mocks base method
func (*MockSeriesIteratorAccumulator) Next ¶ added in v0.15.2
func (m *MockSeriesIteratorAccumulator) Next() bool
Next mocks base method
func (*MockSeriesIteratorAccumulator) Replicas ¶ added in v0.15.2
func (m *MockSeriesIteratorAccumulator) Replicas() ([]MultiReaderIterator, error)
Replicas mocks base method
func (*MockSeriesIteratorAccumulator) Reset ¶ added in v0.15.2
func (m *MockSeriesIteratorAccumulator) Reset(opts SeriesIteratorOptions)
Reset mocks base method
func (*MockSeriesIteratorAccumulator) SetIterateEqualTimestampStrategy ¶ added in v0.15.2
func (m *MockSeriesIteratorAccumulator) SetIterateEqualTimestampStrategy(strategy IterateEqualTimestampStrategy)
SetIterateEqualTimestampStrategy mocks base method
func (*MockSeriesIteratorAccumulator) Start ¶ added in v0.15.2
func (m *MockSeriesIteratorAccumulator) Start() time.Time
Start mocks base method
func (*MockSeriesIteratorAccumulator) Stats ¶ added in v0.15.2
func (m *MockSeriesIteratorAccumulator) Stats() (SeriesIteratorStats, error)
Stats mocks base method
func (*MockSeriesIteratorAccumulator) Tags ¶ added in v0.15.2
func (m *MockSeriesIteratorAccumulator) Tags() ident.TagIterator
Tags mocks base method
type MockSeriesIteratorAccumulatorMockRecorder ¶ added in v0.15.2
type MockSeriesIteratorAccumulatorMockRecorder struct {
// contains filtered or unexported fields
}
MockSeriesIteratorAccumulatorMockRecorder is the mock recorder for MockSeriesIteratorAccumulator
func (*MockSeriesIteratorAccumulatorMockRecorder) Add ¶ added in v0.15.2
func (mr *MockSeriesIteratorAccumulatorMockRecorder) Add(it interface{}) *gomock.Call
Add indicates an expected call of Add
func (*MockSeriesIteratorAccumulatorMockRecorder) Close ¶ added in v0.15.2
func (mr *MockSeriesIteratorAccumulatorMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close
func (*MockSeriesIteratorAccumulatorMockRecorder) Current ¶ added in v0.15.2
func (mr *MockSeriesIteratorAccumulatorMockRecorder) Current() *gomock.Call
Current indicates an expected call of Current
func (*MockSeriesIteratorAccumulatorMockRecorder) End ¶ added in v0.15.2
func (mr *MockSeriesIteratorAccumulatorMockRecorder) End() *gomock.Call
End indicates an expected call of End
func (*MockSeriesIteratorAccumulatorMockRecorder) Err ¶ added in v0.15.2
func (mr *MockSeriesIteratorAccumulatorMockRecorder) Err() *gomock.Call
Err indicates an expected call of Err
func (*MockSeriesIteratorAccumulatorMockRecorder) ID ¶ added in v0.15.2
func (mr *MockSeriesIteratorAccumulatorMockRecorder) ID() *gomock.Call
ID indicates an expected call of ID
func (*MockSeriesIteratorAccumulatorMockRecorder) Namespace ¶ added in v0.15.2
func (mr *MockSeriesIteratorAccumulatorMockRecorder) Namespace() *gomock.Call
Namespace indicates an expected call of Namespace
func (*MockSeriesIteratorAccumulatorMockRecorder) Next ¶ added in v0.15.2
func (mr *MockSeriesIteratorAccumulatorMockRecorder) Next() *gomock.Call
Next indicates an expected call of Next
func (*MockSeriesIteratorAccumulatorMockRecorder) Replicas ¶ added in v0.15.2
func (mr *MockSeriesIteratorAccumulatorMockRecorder) Replicas() *gomock.Call
Replicas indicates an expected call of Replicas
func (*MockSeriesIteratorAccumulatorMockRecorder) Reset ¶ added in v0.15.2
func (mr *MockSeriesIteratorAccumulatorMockRecorder) Reset(opts interface{}) *gomock.Call
Reset indicates an expected call of Reset
func (*MockSeriesIteratorAccumulatorMockRecorder) SetIterateEqualTimestampStrategy ¶ added in v0.15.2
func (mr *MockSeriesIteratorAccumulatorMockRecorder) SetIterateEqualTimestampStrategy(strategy interface{}) *gomock.Call
SetIterateEqualTimestampStrategy indicates an expected call of SetIterateEqualTimestampStrategy
func (*MockSeriesIteratorAccumulatorMockRecorder) Start ¶ added in v0.15.2
func (mr *MockSeriesIteratorAccumulatorMockRecorder) Start() *gomock.Call
Start indicates an expected call of Start
func (*MockSeriesIteratorAccumulatorMockRecorder) Stats ¶ added in v0.15.2
func (mr *MockSeriesIteratorAccumulatorMockRecorder) Stats() *gomock.Call
Stats indicates an expected call of Stats
func (*MockSeriesIteratorAccumulatorMockRecorder) Tags ¶ added in v0.15.2
func (mr *MockSeriesIteratorAccumulatorMockRecorder) Tags() *gomock.Call
Tags indicates an expected call of Tags
type MockSeriesIteratorConsolidator ¶ added in v0.15.0
type MockSeriesIteratorConsolidator struct {
// contains filtered or unexported fields
}
MockSeriesIteratorConsolidator is a mock of SeriesIteratorConsolidator interface
func NewMockSeriesIteratorConsolidator ¶ added in v0.15.0
func NewMockSeriesIteratorConsolidator(ctrl *gomock.Controller) *MockSeriesIteratorConsolidator
NewMockSeriesIteratorConsolidator creates a new mock instance
func (*MockSeriesIteratorConsolidator) ConsolidateReplicas ¶ added in v0.15.0
func (m *MockSeriesIteratorConsolidator) ConsolidateReplicas(replicas []MultiReaderIterator) ([]MultiReaderIterator, error)
ConsolidateReplicas mocks base method
func (*MockSeriesIteratorConsolidator) EXPECT ¶ added in v0.15.0
func (m *MockSeriesIteratorConsolidator) EXPECT() *MockSeriesIteratorConsolidatorMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
type MockSeriesIteratorConsolidatorMockRecorder ¶ added in v0.15.0
type MockSeriesIteratorConsolidatorMockRecorder struct {
// contains filtered or unexported fields
}
MockSeriesIteratorConsolidatorMockRecorder is the mock recorder for MockSeriesIteratorConsolidator
func (*MockSeriesIteratorConsolidatorMockRecorder) ConsolidateReplicas ¶ added in v0.15.0
func (mr *MockSeriesIteratorConsolidatorMockRecorder) ConsolidateReplicas(replicas interface{}) *gomock.Call
ConsolidateReplicas indicates an expected call of ConsolidateReplicas
type MockSeriesIteratorMockRecorder ¶
type MockSeriesIteratorMockRecorder struct {
// contains filtered or unexported fields
}
MockSeriesIteratorMockRecorder is the mock recorder for MockSeriesIterator
func (*MockSeriesIteratorMockRecorder) Close ¶
func (mr *MockSeriesIteratorMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close
func (*MockSeriesIteratorMockRecorder) Current ¶
func (mr *MockSeriesIteratorMockRecorder) Current() *gomock.Call
Current indicates an expected call of Current
func (*MockSeriesIteratorMockRecorder) End ¶
func (mr *MockSeriesIteratorMockRecorder) End() *gomock.Call
End indicates an expected call of End
func (*MockSeriesIteratorMockRecorder) Err ¶
func (mr *MockSeriesIteratorMockRecorder) Err() *gomock.Call
Err indicates an expected call of Err
func (*MockSeriesIteratorMockRecorder) ID ¶
func (mr *MockSeriesIteratorMockRecorder) ID() *gomock.Call
ID indicates an expected call of ID
func (*MockSeriesIteratorMockRecorder) Namespace ¶
func (mr *MockSeriesIteratorMockRecorder) Namespace() *gomock.Call
Namespace indicates an expected call of Namespace
func (*MockSeriesIteratorMockRecorder) Next ¶
func (mr *MockSeriesIteratorMockRecorder) Next() *gomock.Call
Next indicates an expected call of Next
func (*MockSeriesIteratorMockRecorder) Replicas ¶
func (mr *MockSeriesIteratorMockRecorder) Replicas() *gomock.Call
Replicas indicates an expected call of Replicas
func (*MockSeriesIteratorMockRecorder) Reset ¶
func (mr *MockSeriesIteratorMockRecorder) Reset(opts interface{}) *gomock.Call
Reset indicates an expected call of Reset
func (*MockSeriesIteratorMockRecorder) SetIterateEqualTimestampStrategy ¶ added in v0.4.4
func (mr *MockSeriesIteratorMockRecorder) SetIterateEqualTimestampStrategy(strategy interface{}) *gomock.Call
SetIterateEqualTimestampStrategy indicates an expected call of SetIterateEqualTimestampStrategy
func (*MockSeriesIteratorMockRecorder) Start ¶
func (mr *MockSeriesIteratorMockRecorder) Start() *gomock.Call
Start indicates an expected call of Start
func (*MockSeriesIteratorMockRecorder) Stats ¶ added in v0.15.0
func (mr *MockSeriesIteratorMockRecorder) Stats() *gomock.Call
Stats indicates an expected call of Stats
func (*MockSeriesIteratorMockRecorder) Tags ¶
func (mr *MockSeriesIteratorMockRecorder) Tags() *gomock.Call
Tags indicates an expected call of Tags
type MockSeriesIteratorPool ¶
type MockSeriesIteratorPool struct {
// contains filtered or unexported fields
}
MockSeriesIteratorPool is a mock of SeriesIteratorPool interface
func NewMockSeriesIteratorPool ¶
func NewMockSeriesIteratorPool(ctrl *gomock.Controller) *MockSeriesIteratorPool
NewMockSeriesIteratorPool creates a new mock instance
func (*MockSeriesIteratorPool) EXPECT ¶
func (m *MockSeriesIteratorPool) EXPECT() *MockSeriesIteratorPoolMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockSeriesIteratorPool) Get ¶
func (m *MockSeriesIteratorPool) Get() SeriesIterator
Get mocks base method
func (*MockSeriesIteratorPool) Init ¶
func (m *MockSeriesIteratorPool) Init()
Init mocks base method
func (*MockSeriesIteratorPool) Put ¶
func (m *MockSeriesIteratorPool) Put(iter SeriesIterator)
Put mocks base method
type MockSeriesIteratorPoolMockRecorder ¶
type MockSeriesIteratorPoolMockRecorder struct {
// contains filtered or unexported fields
}
MockSeriesIteratorPoolMockRecorder is the mock recorder for MockSeriesIteratorPool
func (*MockSeriesIteratorPoolMockRecorder) Get ¶
func (mr *MockSeriesIteratorPoolMockRecorder) Get() *gomock.Call
Get indicates an expected call of Get
func (*MockSeriesIteratorPoolMockRecorder) Init ¶
func (mr *MockSeriesIteratorPoolMockRecorder) Init() *gomock.Call
Init indicates an expected call of Init
func (*MockSeriesIteratorPoolMockRecorder) Put ¶
func (mr *MockSeriesIteratorPoolMockRecorder) Put(iter interface{}) *gomock.Call
Put indicates an expected call of Put
type MockSeriesIterators ¶
type MockSeriesIterators struct {
// contains filtered or unexported fields
}
MockSeriesIterators is a mock of SeriesIterators interface
func NewMockSeriesIterators ¶
func NewMockSeriesIterators(ctrl *gomock.Controller) *MockSeriesIterators
NewMockSeriesIterators creates a new mock instance
func (*MockSeriesIterators) EXPECT ¶
func (m *MockSeriesIterators) EXPECT() *MockSeriesIteratorsMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockSeriesIterators) Iters ¶
func (m *MockSeriesIterators) Iters() []SeriesIterator
Iters mocks base method
type MockSeriesIteratorsMockRecorder ¶
type MockSeriesIteratorsMockRecorder struct {
// contains filtered or unexported fields
}
MockSeriesIteratorsMockRecorder is the mock recorder for MockSeriesIterators
func (*MockSeriesIteratorsMockRecorder) Close ¶
func (mr *MockSeriesIteratorsMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close
func (*MockSeriesIteratorsMockRecorder) Iters ¶
func (mr *MockSeriesIteratorsMockRecorder) Iters() *gomock.Call
Iters indicates an expected call of Iters
func (*MockSeriesIteratorsMockRecorder) Len ¶
func (mr *MockSeriesIteratorsMockRecorder) Len() *gomock.Call
Len indicates an expected call of Len
type MultiReaderIterator ¶
type MultiReaderIterator interface { Iterator // Reset resets the iterator to read from a slice of readers // with a new schema (for schema aware iterators). Reset(readers []xio.SegmentReader, start time.Time, blockSize time.Duration, schema namespace.SchemaDescr) // Reset resets the iterator to read from a slice of slice readers // with a new schema (for schema aware iterators). ResetSliceOfSlices( readers xio.ReaderSliceOfSlicesIterator, schema namespace.SchemaDescr, ) // Readers exposes the underlying ReaderSliceOfSlicesIterator // for this MultiReaderIterator. Readers() xio.ReaderSliceOfSlicesIterator // Schema exposes the underlying SchemaDescr for this 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 NewEncoderFn ¶
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.
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.
Source Files
¶
- encoder_pool.go
- encoding.go
- encoding_mock.go
- istream.go
- iterator_pool.go
- iterators.go
- iterators_types.go
- multi_reader_iterator.go
- multi_reader_iterator_array_pool.go
- mutable_series_iterators_pool.go
- null.go
- options.go
- ostream.go
- scheme.go
- series_iterator.go
- series_iterator_accumulator.go
- series_iterator_pool.go
- series_iterators.go
- types.go