encoding

package

Go to main page

Versions in this module

v0

v0.15.0-rc.2-shard-host-queues

Apr 28, 2020

v0.9.6

May 29, 2019

v0.9.5

May 28, 2019

v0.9.4

May 21, 2019

v0.9.3

May 21, 2019

v0.9.2

May 18, 2019

Changes in this version

type Encoder

+ SetSchema func(descr namespace.SchemaDescr)

type MockEncoder

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

type MockEncoderMockRecorder

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

+ type StreamOptions struct

+ Bytes checked.Bytes

v0.9.1

May 13, 2019

v0.9.0

May 6, 2019

v0.8.4

Apr 20, 2019

v0.8.3

Apr 13, 2019

v0.8.2

Apr 11, 2019

Changes in this version

type IStream

+ Read func([]byte) (int, error)

+ RemainingBitsInCurrentByte func() int

type MockIStream

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

+ func (m *MockIStream) RemainingBitsInCurrentByte() int

type MockIStreamMockRecorder

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

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

type MockOStream

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

type MockOStreamMockRecorder

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

type MockOptions

+ func (m *MockOptions) ByteFieldDictionaryLRUSize() int

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

type MockOptionsMockRecorder

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

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

type OStream

+ Write func(bytes []byte) (int, error)

type Options

+ ByteFieldDictionaryLRUSize func() int

+ SetByteFieldDictionaryLRUSize func(value int) Options

v0.8.1

Apr 2, 2019

v0.8.0

Mar 29, 2019

v0.7.3

Mar 21, 2019

v0.7.2

Mar 16, 2019

v0.7.1

Mar 15, 2019

v0.7.0

Mar 12, 2019

v0.6.1

Feb 20, 2019

v0.6.0

Feb 20, 2019

v0.5.0

Feb 3, 2019

v0.4.8

Nov 19, 2018

v0.4.7

Oct 10, 2018

v0.4.6

Oct 5, 2018

Changes in this version

type SeriesIterators

+ var EmptySeriesIterators SeriesIterators = emptyIters{}

v0.4.5

Sep 25, 2018

v0.4.4

Sep 21, 2018

Changes in this version

type Encoder

+ LastEncoded func() (ts.Datapoint, error)

+ NumEncoded func() int

+ type IterateEqualTimestampStrategy uint8

+ const DefaultIterateEqualTimestampStrategy

+ const IterateHighestFrequencyValue

+ const IterateHighestValue

+ const IterateLastPushed

+ const IterateLowestValue

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

+ func ValidIterateEqualTimestampStrategies() []IterateEqualTimestampStrategy

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

+ func (s IterateEqualTimestampStrategy) String() string

type MockEncoder

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

+ func (m *MockEncoder) NumEncoded() int

type MockEncoderMockRecorder

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

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

type MockSeriesIterator

+ func (m *MockSeriesIterator) SetIterateEqualTimestampStrategy(strategy IterateEqualTimestampStrategy)

type MockSeriesIteratorMockRecorder

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

type SeriesIterator

+ SetIterateEqualTimestampStrategy func(strategy IterateEqualTimestampStrategy)

+ type SeriesIteratorOptions struct

+ EndExclusive time.Time

+ ID ident.ID

+ IterateEqualTimestampStrategy IterateEqualTimestampStrategy

+ Namespace ident.ID

+ Replicas []MultiReaderIterator

+ StartInclusive time.Time

+ Tags ident.TagIterator

v0.4.3

Sep 6, 2018

v0.4.2

Aug 30, 2018

v0.4.1

Aug 27, 2018

v0.4.0

Aug 10, 2018

v0.3.0

Jul 16, 2018

Changes in this version

type IteratorPools

+ MutableSeriesIterators func() MutableSeriesIteratorsPool

+ TagDecoder func() serialize.TagDecoderPool

+ TagEncoder func() serialize.TagEncoderPool

type MockIteratorPools

+ func (m *MockIteratorPools) MutableSeriesIterators() MutableSeriesIteratorsPool

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

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

type MockIteratorPoolsMockRecorder

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

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

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

v0.2.0

May 26, 2018

v0.1.0

May 24, 2018

Changes in this version

+ func LeadingAndTrailingZeros(v uint64) (int, int)

+ func NumSig(v uint64) uint8

+ func SignExtend(v uint64, numBits int) int64

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

+ type Bit byte

+ type Decoder interface

+ Decode func(reader io.Reader) ReaderIterator

+ type Encoder interface

+ Close func()

+ Discard func() ts.Segment

+ DiscardReset func(t time.Time, capacity int) ts.Segment

+ Encode func(dp ts.Datapoint, unit xtime.Unit, annotation ts.Annotation) error

+ Len func() int

+ Reset func(t time.Time, capacity int)

+ Stream func() xio.SegmentReader

+ func NewNullEncoder() Encoder

+ type EncoderAllocate func() Encoder

+ type EncoderPool interface

+ Get func() Encoder

+ Init func(alloc EncoderAllocate)

+ Put func(e Encoder)

+ func NewEncoderPool(opts pool.ObjectPoolOptions) EncoderPool

+ type IStream interface

+ PeekBits func(numBits int) (uint64, error)

+ ReadBit func() (Bit, error)

+ ReadBits func(numBits int) (uint64, error)

+ ReadByte func() (byte, error)

+ Reset func(r io.Reader)

+ func NewIStream(reader io.Reader) IStream

+ type Iterator interface

+ Close func()

+ Current func() (ts.Datapoint, xtime.Unit, ts.Annotation)

+ Err func() error

+ Next func() bool

+ type IteratorPools interface

+ CheckedBytesWrapper func() xpool.CheckedBytesWrapperPool

+ ID func() ident.Pool

+ MultiReaderIterator func() MultiReaderIteratorPool

+ MultiReaderIteratorArray func() MultiReaderIteratorArrayPool

+ SeriesIterator func() SeriesIteratorPool

+ type Marker byte

+ type MarkerEncodingScheme interface

+ Annotation func() Marker

+ EndOfStream func() Marker

+ NumOpcodeBits func() int

+ NumValueBits func() int

+ Opcode func() uint64

+ Tail func(streamLastByte byte, streamCurrentPosition int) checked.Bytes

+ TimeUnit func() Marker

+ type MockDecoder struct

+ func NewMockDecoder(ctrl *gomock.Controller) *MockDecoder

+ func (m *MockDecoder) Decode(reader io.Reader) ReaderIterator

+ func (m *MockDecoder) EXPECT() *MockDecoderMockRecorder

+ type MockDecoderMockRecorder struct

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

+ type MockEncoder struct

+ func NewMockEncoder(ctrl *gomock.Controller) *MockEncoder

+ func (m *MockEncoder) Close()

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

+ func (m *MockEncoder) DiscardReset(t time.Time, capacity int) ts.Segment

+ func (m *MockEncoder) EXPECT() *MockEncoderMockRecorder

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

+ func (m *MockEncoder) Len() int

+ func (m *MockEncoder) Reset(t time.Time, capacity int)

+ func (m *MockEncoder) Stream() xio.SegmentReader

+ type MockEncoderMockRecorder struct

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

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

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

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

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

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

+ func (mr *MockEncoderMockRecorder) Stream() *gomock.Call

+ type MockEncoderPool struct

+ func NewMockEncoderPool(ctrl *gomock.Controller) *MockEncoderPool

+ func (m *MockEncoderPool) EXPECT() *MockEncoderPoolMockRecorder

+ func (m *MockEncoderPool) Get() Encoder

+ func (m *MockEncoderPool) Init(alloc EncoderAllocate)

+ func (m *MockEncoderPool) Put(e Encoder)

+ type MockEncoderPoolMockRecorder struct

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

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

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

+ type MockIStream struct

+ func NewMockIStream(ctrl *gomock.Controller) *MockIStream

+ func (m *MockIStream) EXPECT() *MockIStreamMockRecorder

+ func (m *MockIStream) PeekBits(numBits int) (uint64, error)

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

+ func (m *MockIStream) ReadBits(numBits int) (uint64, error)

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

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

+ type MockIStreamMockRecorder struct

+ func (mr *MockIStreamMockRecorder) PeekBits(numBits 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) Reset(r interface{}) *gomock.Call

+ type MockIterator struct

+ func NewMockIterator(ctrl *gomock.Controller) *MockIterator

+ func (m *MockIterator) Close()

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

+ func (m *MockIterator) EXPECT() *MockIteratorMockRecorder

+ func (m *MockIterator) Err() error

+ func (m *MockIterator) Next() bool

+ type MockIteratorMockRecorder struct

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

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

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

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

+ type MockIteratorPools struct

+ func NewMockIteratorPools(ctrl *gomock.Controller) *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) SeriesIterator() SeriesIteratorPool

+ type MockIteratorPoolsMockRecorder struct

+ 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) SeriesIterator() *gomock.Call

+ type MockMultiReaderIterator struct

+ func NewMockMultiReaderIterator(ctrl *gomock.Controller) *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)

+ type MockMultiReaderIteratorArrayPool struct

+ func NewMockMultiReaderIteratorArrayPool(ctrl *gomock.Controller) *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 struct

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

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

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

+ type MockMultiReaderIteratorMockRecorder struct

+ 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 interface{}) *gomock.Call

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

+ type MockMultiReaderIteratorPool struct

+ func NewMockMultiReaderIteratorPool(ctrl *gomock.Controller) *MockMultiReaderIteratorPool

+ func (m *MockMultiReaderIteratorPool) EXPECT() *MockMultiReaderIteratorPoolMockRecorder

+ func (m *MockMultiReaderIteratorPool) Get() MultiReaderIterator

+ func (m *MockMultiReaderIteratorPool) Init(alloc ReaderIteratorAllocate)

+ func (m *MockMultiReaderIteratorPool) Put(iter MultiReaderIterator)

+ type MockMultiReaderIteratorPoolMockRecorder struct

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

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

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

+ type MockMutableSeriesIterators struct

+ func NewMockMutableSeriesIterators(ctrl *gomock.Controller) *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 struct

+ 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 struct

+ func NewMockMutableSeriesIteratorsPool(ctrl *gomock.Controller) *MockMutableSeriesIteratorsPool

+ func (m *MockMutableSeriesIteratorsPool) EXPECT() *MockMutableSeriesIteratorsPoolMockRecorder

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

+ func (m *MockMutableSeriesIteratorsPool) Init()

+ func (m *MockMutableSeriesIteratorsPool) Put(iters MutableSeriesIterators)

+ type MockMutableSeriesIteratorsPoolMockRecorder struct

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

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

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

+ type MockOStream struct

+ func NewMockOStream(ctrl *gomock.Controller) *MockOStream

+ 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() (checked.Bytes, int)

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

+ 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 struct

+ 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) 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 struct

+ func NewMockOptions(ctrl *gomock.Controller) *MockOptions

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

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

+ func (m *MockOptions) EXPECT() *MockOptionsMockRecorder

+ func (m *MockOptions) EncoderPool() EncoderPool

+ func (m *MockOptions) MarkerEncodingScheme() MarkerEncodingScheme

+ func (m *MockOptions) ReaderIteratorPool() ReaderIteratorPool

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

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

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

+ func (m *MockOptions) SetEncoderPool(value EncoderPool) 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 TimeEncodingSchemes) Options

+ func (m *MockOptions) TimeEncodingSchemes() TimeEncodingSchemes

+ type MockOptionsMockRecorder struct

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

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

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

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

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

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

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

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

+ func (mr *MockOptionsMockRecorder) SetEncoderPool(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 struct

+ func NewMockReaderIterator(ctrl *gomock.Controller) *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)

+ type MockReaderIteratorMockRecorder struct

+ 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 interface{}) *gomock.Call

+ type MockReaderIteratorPool struct

+ func NewMockReaderIteratorPool(ctrl *gomock.Controller) *MockReaderIteratorPool

+ func (m *MockReaderIteratorPool) EXPECT() *MockReaderIteratorPoolMockRecorder

+ func (m *MockReaderIteratorPool) Get() ReaderIterator

+ func (m *MockReaderIteratorPool) Init(alloc ReaderIteratorAllocate)

+ func (m *MockReaderIteratorPool) Put(iter ReaderIterator)

+ type MockReaderIteratorPoolMockRecorder struct

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

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

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

+ type MockSeriesIterator struct

+ func NewMockSeriesIterator(ctrl *gomock.Controller) *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

+ func (m *MockSeriesIterator) Reset(id, ns ident.ID, t ident.TagIterator, startInclusive, endExclusive time.Time, ...)

+ func (m *MockSeriesIterator) Start() time.Time

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

+ type MockSeriesIteratorMockRecorder struct

+ 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(id, ns, t, startInclusive, endExclusive, replicas interface{}) *gomock.Call

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

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

+ type MockSeriesIteratorPool struct

+ func NewMockSeriesIteratorPool(ctrl *gomock.Controller) *MockSeriesIteratorPool

+ func (m *MockSeriesIteratorPool) EXPECT() *MockSeriesIteratorPoolMockRecorder

+ func (m *MockSeriesIteratorPool) Get() SeriesIterator

+ func (m *MockSeriesIteratorPool) Init()

+ func (m *MockSeriesIteratorPool) Put(iter SeriesIterator)

+ type MockSeriesIteratorPoolMockRecorder struct

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

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

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

+ type MockSeriesIterators struct

+ func NewMockSeriesIterators(ctrl *gomock.Controller) *MockSeriesIterators

+ func (m *MockSeriesIterators) Close()

+ func (m *MockSeriesIterators) EXPECT() *MockSeriesIteratorsMockRecorder

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

+ func (m *MockSeriesIterators) Len() int

+ type MockSeriesIteratorsMockRecorder struct

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

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

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

+ type MultiReaderIterator interface

+ Readers func() xio.ReaderSliceOfSlicesIterator

+ Reset func(readers []xio.SegmentReader, start time.Time, blockSize time.Duration)

+ ResetSliceOfSlices func(readers xio.ReaderSliceOfSlicesIterator)

+ func NewMultiReaderIterator(iteratorAlloc ReaderIteratorAllocate, pool MultiReaderIteratorPool) MultiReaderIterator

+ type MultiReaderIteratorArrayPool interface

+ Get func(size int) []MultiReaderIterator

+ Init func()

+ Put func(iters []MultiReaderIterator)

+ func NewMultiReaderIteratorArrayPool(sizes []pool.Bucket) MultiReaderIteratorArrayPool

+ type MultiReaderIteratorPool interface

+ Get func() MultiReaderIterator

+ Init func(alloc ReaderIteratorAllocate)

+ Put func(iter MultiReaderIterator)

+ func NewMultiReaderIteratorPool(opts pool.ObjectPoolOptions) MultiReaderIteratorPool

+ type MutableSeriesIterators interface

+ Cap func() int

+ Reset func(size int)

+ SetAt func(idx int, iter SeriesIterator)

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

+ type MutableSeriesIteratorsPool interface

+ Get func(size int) MutableSeriesIterators

+ Init func()

+ Put func(iters MutableSeriesIterators)

+ func NewMutableSeriesIteratorsPool(sizes []pool.Bucket) MutableSeriesIteratorsPool

+ type NewDecoderFn func() Decoder

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

+ type OStream interface

+ Discard func() checked.Bytes

+ Empty func() bool

+ Len func() int

+ Rawbytes func() (checked.Bytes, int)

+ Reset func(buffer checked.Bytes)

+ WriteBit func(v Bit)

+ WriteBits func(v uint64, numBits int)

+ WriteByte func(v byte)

+ WriteBytes func(bytes []byte)

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

+ type Options interface

+ BytesPool func() pool.CheckedBytesPool

+ DefaultTimeUnit func() xtime.Unit

+ EncoderPool func() EncoderPool

+ MarkerEncodingScheme func() MarkerEncodingScheme

+ ReaderIteratorPool func() ReaderIteratorPool

+ SegmentReaderPool func() xio.SegmentReaderPool

+ SetBytesPool func(value pool.CheckedBytesPool) Options

+ SetDefaultTimeUnit func(tu xtime.Unit) Options

+ SetEncoderPool func(value EncoderPool) Options

+ SetMarkerEncodingScheme func(value MarkerEncodingScheme) Options

+ SetReaderIteratorPool func(value ReaderIteratorPool) Options

+ SetSegmentReaderPool func(value xio.SegmentReaderPool) Options

+ SetTimeEncodingSchemes func(value TimeEncodingSchemes) Options

+ TimeEncodingSchemes func() TimeEncodingSchemes

+ func NewOptions() Options

+ type ReaderIterator interface

+ Reset func(reader io.Reader)

+ func NewNullReaderIterator() ReaderIterator

+ type ReaderIteratorAllocate func(reader io.Reader) ReaderIterator

+ type ReaderIteratorPool interface

+ Get func() ReaderIterator

+ Init func(alloc ReaderIteratorAllocate)

+ Put func(iter ReaderIterator)

+ func NewReaderIteratorPool(opts pool.ObjectPoolOptions) ReaderIteratorPool

+ type SeriesIterator interface

+ End func() time.Time

+ ID func() ident.ID

+ Namespace func() ident.ID

+ Replicas func() []MultiReaderIterator

+ Reset func(id ident.ID, ns ident.ID, t ident.TagIterator, ...)

+ Start func() time.Time

+ Tags func() ident.TagIterator

+ func NewSeriesIterator(id ident.ID, nsID ident.ID, tags ident.TagIterator, ...) SeriesIterator

+ type SeriesIteratorPool interface

+ Get func() SeriesIterator

+ Init func()

+ Put func(iter SeriesIterator)

+ func NewSeriesIteratorPool(opts pool.ObjectPoolOptions) SeriesIteratorPool

+ type SeriesIterators interface

+ Close func()

+ Iters func() []SeriesIterator

+ Len func() int

+ type TimeBucket interface

+ Max func() int64

+ Min func() int64

+ NumOpcodeBits func() int

+ NumValueBits func() int

+ Opcode func() uint64

+ type TimeEncodingScheme interface

+ Buckets func() []TimeBucket

+ DefaultBucket func() TimeBucket

+ ZeroBucket func() TimeBucket

+ type TimeEncodingSchemes map[xtime.Unit]TimeEncodingScheme

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