Documentation

Overview

    Package encoding is a generated GoMock package.

    Index

    Constants

    This section is empty.

    Variables

    This section is empty.

    Functions

    func LeadingAndTrailingZeros

    func LeadingAndTrailingZeros(v uint64) (int, int)

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

      func NumSig

      func NumSig(v uint64) uint8

        NumSig returns the number of significant bits in a uint64.

        func SignExtend

        func SignExtend(v uint64, numBits uint) int64

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

          func WriteSpecialMarker

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

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

            Types

            type Bit

            type Bit byte

              Bit is just a byte.

              type Decoder

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

                Decoder is the generic interface for different types of decoders.

                type Encoder

                type Encoder interface {
                	// SetSchema sets up the schema needed by schema-aware encoder to encode the stream.
                	// SetSchema can be called multiple times between reset for mid-stream schema changes.
                	SetSchema(descr namespace.SchemaDescr)
                
                	// Encode encodes a datapoint and optionally an annotation.
                	// Schema must be set prior to Encode for schema-aware encoder. A schema can be set
                	// via Reset/DiscardReset/SetSchema.
                	Encode(dp ts.Datapoint, unit xtime.Unit, annotation ts.Annotation) error
                
                	// Stream is the streaming interface for reading encoded bytes in the encoder.
                	// A boolean is returned indicating whether the returned xio.SegmentReader contains
                	// any data (true) or is empty (false) to encourage callers to remember to handle
                	// the special case where there is an empty stream.
                	// NB(r): The underlying byte slice will not be returned to the pool until the context
                	// passed to this method is closed, so to avoid not returning the
                	// encoder's buffer back to the pool when it is completed be sure to call
                	// close on the context eventually.
                	Stream(ctx xcontext.Context) (xio.SegmentReader, bool)
                
                	// NumEncoded returns the number of encoded datapoints.
                	NumEncoded() int
                
                	// LastEncoded returns the last encoded datapoint, useful for
                	// de-duplicating encoded values. If there are no previously encoded values
                	// an error is returned.
                	LastEncoded() (ts.Datapoint, error)
                
                	// LastAnnotationChecksum returns the checksum of the last annotation, useful for
                	// de-duplicating encoded values. If there are no previously encoded values
                	// an error is returned.
                	LastAnnotationChecksum() (uint64, error)
                
                	// Len returns the length of the encoded stream as returned by a call to Stream().
                	Len() int
                
                	// Reset resets the start time of the encoder and the internal state.
                	// Reset sets up the schema for schema-aware encoders such as proto encoders.
                	Reset(t time.Time, capacity int, schema namespace.SchemaDescr)
                
                	// Close closes the encoder and if pooled will return it to the pool.
                	Close()
                
                	// Discard will take ownership of the encoder data and if pooled will return the encoder to the pool.
                	Discard() ts.Segment
                
                	// DiscardReset will take ownership of the encoder data and reset the encoder for reuse.
                	// DiscardReset sets up the schema for schema-aware encoders such as proto encoders.
                	DiscardReset(t time.Time, capacity int, schema namespace.SchemaDescr) ts.Segment
                }

                  Encoder is the generic interface for different types of encoders.

                  func NewNullEncoder

                  func NewNullEncoder() Encoder

                    NewNullEncoder returns a new encoder that performs no operations

                    type EncoderAllocate

                    type EncoderAllocate func() Encoder

                      EncoderAllocate allocates an encoder for a pool.

                      type EncoderPool

                      type EncoderPool interface {
                      	// Init initializes the pool.
                      	Init(alloc EncoderAllocate)
                      
                      	// Get provides an encoder from the pool.
                      	Get() Encoder
                      
                      	// Put returns an encoder to the pool.
                      	Put(e Encoder)
                      }

                        EncoderPool provides a pool for encoders.

                        func NewEncoderPool

                        func NewEncoderPool(opts pool.ObjectPoolOptions) EncoderPool

                          NewEncoderPool creates a new pool

                          type IStream

                          type IStream interface {
                          	// Read reads len(b) bytes.
                          	Read([]byte) (int, error)
                          
                          	// ReadBit reads the next Bit.
                          	ReadBit() (Bit, error)
                          
                          	// ReadByte reads the next Byte.
                          	ReadByte() (byte, error)
                          
                          	// ReadBits reads the next Bits.
                          	ReadBits(numBits uint) (uint64, error)
                          
                          	// PeekBits looks at the next Bits, but doesn't move the pos.
                          	PeekBits(numBits uint) (uint64, error)
                          
                          	// RemainingBitsInCurrentByte returns the number of bits remaining to
                          	// be read in the current byte.
                          	RemainingBitsInCurrentByte() uint
                          
                          	// Reset resets the IStream.
                          	Reset(r io.Reader)
                          }

                            IStream encapsulates a readable stream.

                            func NewIStream

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

                              NewIStream creates a new Istream

                              type IterateEqualTimestampStrategy

                              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

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

                                  ParseIterateEqualTimestampStrategy parses a IterateEqualTimestampStrategy from a string.

                                  func ValidIterateEqualTimestampStrategies

                                  func ValidIterateEqualTimestampStrategies() []IterateEqualTimestampStrategy

                                    ValidIterateEqualTimestampStrategies returns the valid iterate equal timestamp strategies.

                                    func (IterateEqualTimestampStrategy) String

                                    func (*IterateEqualTimestampStrategy) UnmarshalYAML

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

                                      UnmarshalYAML unmarshals an IterateEqualTimestampStrategy into a valid type from string.

                                      type Iterator

                                      type Iterator interface {
                                      	// Next moves to the next item.
                                      	Next() bool
                                      
                                      	// Current returns the value as well as the annotation associated with the
                                      	// current datapoint. Users should not hold on to the returned Annotation
                                      	// object as it may get invalidated when the iterator calls Next().
                                      	Current() (ts.Datapoint, xtime.Unit, ts.Annotation)
                                      
                                      	// Err returns the error encountered.
                                      	Err() error
                                      
                                      	// Close closes the iterator and if pooled will return to the pool.
                                      	Close()
                                      }

                                        Iterator is the generic interface for iterating over encoded data.

                                        type IteratorPools

                                        type IteratorPools interface {
                                        	// MultiReaderIteratorArray exposes the session MultiReaderIteratorArrayPool.
                                        	MultiReaderIteratorArray() MultiReaderIteratorArrayPool
                                        
                                        	// MultiReaderIterator exposes the session MultiReaderIteratorPool.
                                        	MultiReaderIterator() MultiReaderIteratorPool
                                        
                                        	// MutableSeriesIterators exposes the session MutableSeriesIteratorsPool.
                                        	MutableSeriesIterators() MutableSeriesIteratorsPool
                                        
                                        	// SeriesIterator exposes the session SeriesIteratorPool.
                                        	SeriesIterator() SeriesIteratorPool
                                        
                                        	// CheckedBytesWrapper exposes the session CheckedBytesWrapperPool.
                                        	CheckedBytesWrapper() xpool.CheckedBytesWrapperPool
                                        
                                        	// ID exposes the session identity pool.
                                        	ID() ident.Pool
                                        
                                        	// TagEncoder exposes the session tag encoder pool.
                                        	TagEncoder() serialize.TagEncoderPool
                                        
                                        	// TagDecoder exposes the session tag decoder pool.
                                        	TagDecoder() serialize.TagDecoderPool
                                        }

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

                                          type Marker

                                          type Marker byte

                                            Marker represents the markers.

                                            type MarkerEncodingScheme

                                            type MarkerEncodingScheme interface {
                                            
                                            	// Opcode returns the marker opcode.
                                            	Opcode() uint64
                                            
                                            	// NumOpcodeBits returns the number of bits used for the opcode.
                                            	NumOpcodeBits() int
                                            
                                            	// NumValueBits returns the number of bits used for the marker value.
                                            	NumValueBits() int
                                            
                                            	// EndOfStream returns the end of stream marker.
                                            	EndOfStream() Marker
                                            
                                            	// Annotation returns the annotation marker.
                                            	Annotation() Marker
                                            
                                            	// TimeUnit returns the time unit marker.
                                            	TimeUnit() Marker
                                            
                                            	// Tail will return the tail portion of a stream including the relevant bits
                                            	// in the last byte along with the end of stream marker.
                                            	Tail(streamLastByte byte, streamCurrentPosition int) checked.Bytes
                                            }

                                              MarkerEncodingScheme captures the information related to marker encoding.

                                              type MockDecoder

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

                                                MockDecoder is a mock of Decoder interface

                                                func NewMockDecoder

                                                func NewMockDecoder(ctrl *gomock.Controller) *MockDecoder

                                                  NewMockDecoder creates a new mock instance

                                                  func (*MockDecoder) Decode

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

                                                    Decode mocks base method

                                                    func (*MockDecoder) EXPECT

                                                    func (m *MockDecoder) EXPECT() *MockDecoderMockRecorder

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

                                                      type MockDecoderMockRecorder

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

                                                        MockDecoderMockRecorder is the mock recorder for MockDecoder

                                                        func (*MockDecoderMockRecorder) Decode

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

                                                          Decode indicates an expected call of Decode

                                                          type MockEncoder

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

                                                            MockEncoder is a mock of Encoder interface

                                                            func NewMockEncoder

                                                            func NewMockEncoder(ctrl *gomock.Controller) *MockEncoder

                                                              NewMockEncoder creates a new mock instance

                                                              func (*MockEncoder) Close

                                                              func (m *MockEncoder) Close()

                                                                Close mocks base method

                                                                func (*MockEncoder) Discard

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

                                                                  Discard mocks base method

                                                                  func (*MockEncoder) DiscardReset

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

                                                                    DiscardReset mocks base method

                                                                    func (*MockEncoder) EXPECT

                                                                    func (m *MockEncoder) EXPECT() *MockEncoderMockRecorder

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

                                                                      func (*MockEncoder) Encode

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

                                                                        Encode mocks base method

                                                                        func (*MockEncoder) LastAnnotationChecksum

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

                                                                          LastAnnotationChecksum mocks base method

                                                                          func (*MockEncoder) LastEncoded

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

                                                                            LastEncoded mocks base method

                                                                            func (*MockEncoder) Len

                                                                            func (m *MockEncoder) Len() int

                                                                              Len mocks base method

                                                                              func (*MockEncoder) NumEncoded

                                                                              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

                                                                                  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

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

                                                                                                  LastAnnotationChecksum indicates an expected call of LastAnnotationChecksum

                                                                                                  func (*MockEncoderMockRecorder) LastEncoded

                                                                                                  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

                                                                                                      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

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

                                                                                                            SetSchema indicates an expected call of SetSchema

                                                                                                            func (*MockEncoderMockRecorder) Stream

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

                                                                                                              Stream indicates an expected call of Stream

                                                                                                              type MockEncoderPool

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

                                                                                                                MockEncoderPool is a mock of EncoderPool interface

                                                                                                                func NewMockEncoderPool

                                                                                                                func NewMockEncoderPool(ctrl *gomock.Controller) *MockEncoderPool

                                                                                                                  NewMockEncoderPool creates a new mock instance

                                                                                                                  func (*MockEncoderPool) EXPECT

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

                                                                                                                    func (*MockEncoderPool) Get

                                                                                                                    func (m *MockEncoderPool) Get() Encoder

                                                                                                                      Get mocks base method

                                                                                                                      func (*MockEncoderPool) Init

                                                                                                                      func (m *MockEncoderPool) Init(alloc EncoderAllocate)

                                                                                                                        Init mocks base method

                                                                                                                        func (*MockEncoderPool) Put

                                                                                                                        func (m *MockEncoderPool) Put(e Encoder)

                                                                                                                          Put mocks base method

                                                                                                                          type MockEncoderPoolMockRecorder

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

                                                                                                                            MockEncoderPoolMockRecorder is the mock recorder for MockEncoderPool

                                                                                                                            func (*MockEncoderPoolMockRecorder) Get

                                                                                                                              Get indicates an expected call of Get

                                                                                                                              func (*MockEncoderPoolMockRecorder) Init

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

                                                                                                                                Init indicates an expected call of Init

                                                                                                                                func (*MockEncoderPoolMockRecorder) Put

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

                                                                                                                                  Put indicates an expected call of Put

                                                                                                                                  type MockIStream

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

                                                                                                                                    MockIStream is a mock of IStream interface

                                                                                                                                    func NewMockIStream

                                                                                                                                    func NewMockIStream(ctrl *gomock.Controller) *MockIStream

                                                                                                                                      NewMockIStream creates a new mock instance

                                                                                                                                      func (*MockIStream) EXPECT

                                                                                                                                      func (m *MockIStream) EXPECT() *MockIStreamMockRecorder

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

                                                                                                                                        func (*MockIStream) PeekBits

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

                                                                                                                                          PeekBits mocks base method

                                                                                                                                          func (*MockIStream) Read

                                                                                                                                          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

                                                                                                                                                  func (m *MockIStream) RemainingBitsInCurrentByte() uint

                                                                                                                                                    RemainingBitsInCurrentByte mocks base method

                                                                                                                                                    func (*MockIStream) Reset

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

                                                                                                                                                      Reset mocks base method

                                                                                                                                                      type MockIStreamMockRecorder

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

                                                                                                                                                        MockIStreamMockRecorder is the mock recorder for MockIStream

                                                                                                                                                        func (*MockIStreamMockRecorder) PeekBits

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

                                                                                                                                                          PeekBits indicates an expected call of PeekBits

                                                                                                                                                          func (*MockIStreamMockRecorder) Read

                                                                                                                                                          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

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

                                                                                                                                                                    RemainingBitsInCurrentByte indicates an expected call of RemainingBitsInCurrentByte

                                                                                                                                                                    func (*MockIStreamMockRecorder) Reset

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

                                                                                                                                                                      Reset indicates an expected call of Reset

                                                                                                                                                                      type MockIterator

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

                                                                                                                                                                        MockIterator is a mock of Iterator interface

                                                                                                                                                                        func NewMockIterator

                                                                                                                                                                        func NewMockIterator(ctrl *gomock.Controller) *MockIterator

                                                                                                                                                                          NewMockIterator creates a new mock instance

                                                                                                                                                                          func (*MockIterator) Close

                                                                                                                                                                          func (m *MockIterator) Close()

                                                                                                                                                                            Close mocks base method

                                                                                                                                                                            func (*MockIterator) Current

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

                                                                                                                                                                              Current mocks base method

                                                                                                                                                                              func (*MockIterator) EXPECT

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

                                                                                                                                                                                func (*MockIterator) Err

                                                                                                                                                                                func (m *MockIterator) Err() error

                                                                                                                                                                                  Err mocks base method

                                                                                                                                                                                  func (*MockIterator) Next

                                                                                                                                                                                  func (m *MockIterator) Next() bool

                                                                                                                                                                                    Next mocks base method

                                                                                                                                                                                    type MockIteratorMockRecorder

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

                                                                                                                                                                                      MockIteratorMockRecorder is the mock recorder for MockIterator

                                                                                                                                                                                      func (*MockIteratorMockRecorder) Close

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

                                                                                                                                                                                        Close indicates an expected call of Close

                                                                                                                                                                                        func (*MockIteratorMockRecorder) Current

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

                                                                                                                                                                                          Current indicates an expected call of Current

                                                                                                                                                                                          func (*MockIteratorMockRecorder) Err

                                                                                                                                                                                            Err indicates an expected call of Err

                                                                                                                                                                                            func (*MockIteratorMockRecorder) Next

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

                                                                                                                                                                                              Next indicates an expected call of Next

                                                                                                                                                                                              type MockIteratorPools

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

                                                                                                                                                                                                MockIteratorPools is a mock of IteratorPools interface

                                                                                                                                                                                                func NewMockIteratorPools

                                                                                                                                                                                                func NewMockIteratorPools(ctrl *gomock.Controller) *MockIteratorPools

                                                                                                                                                                                                  NewMockIteratorPools creates a new mock instance

                                                                                                                                                                                                  func (*MockIteratorPools) CheckedBytesWrapper

                                                                                                                                                                                                  func (m *MockIteratorPools) CheckedBytesWrapper() xpool.CheckedBytesWrapperPool

                                                                                                                                                                                                    CheckedBytesWrapper mocks base method

                                                                                                                                                                                                    func (*MockIteratorPools) EXPECT

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

                                                                                                                                                                                                      func (*MockIteratorPools) ID

                                                                                                                                                                                                      func (m *MockIteratorPools) ID() ident.Pool

                                                                                                                                                                                                        ID mocks base method

                                                                                                                                                                                                        func (*MockIteratorPools) MultiReaderIterator

                                                                                                                                                                                                        func (m *MockIteratorPools) MultiReaderIterator() MultiReaderIteratorPool

                                                                                                                                                                                                          MultiReaderIterator mocks base method

                                                                                                                                                                                                          func (*MockIteratorPools) MultiReaderIteratorArray

                                                                                                                                                                                                          func (m *MockIteratorPools) MultiReaderIteratorArray() MultiReaderIteratorArrayPool

                                                                                                                                                                                                            MultiReaderIteratorArray mocks base method

                                                                                                                                                                                                            func (*MockIteratorPools) MutableSeriesIterators

                                                                                                                                                                                                            func (m *MockIteratorPools) MutableSeriesIterators() MutableSeriesIteratorsPool

                                                                                                                                                                                                              MutableSeriesIterators mocks base method

                                                                                                                                                                                                              func (*MockIteratorPools) SeriesIterator

                                                                                                                                                                                                              func (m *MockIteratorPools) SeriesIterator() SeriesIteratorPool

                                                                                                                                                                                                                SeriesIterator mocks base method

                                                                                                                                                                                                                func (*MockIteratorPools) TagDecoder

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

                                                                                                                                                                                                                  TagDecoder mocks base method

                                                                                                                                                                                                                  func (*MockIteratorPools) TagEncoder

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

                                                                                                                                                                                                                    TagEncoder mocks base method

                                                                                                                                                                                                                    type MockIteratorPoolsMockRecorder

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

                                                                                                                                                                                                                      MockIteratorPoolsMockRecorder is the mock recorder for MockIteratorPools

                                                                                                                                                                                                                      func (*MockIteratorPoolsMockRecorder) CheckedBytesWrapper

                                                                                                                                                                                                                      func (mr *MockIteratorPoolsMockRecorder) CheckedBytesWrapper() *gomock.Call

                                                                                                                                                                                                                        CheckedBytesWrapper indicates an expected call of CheckedBytesWrapper

                                                                                                                                                                                                                        func (*MockIteratorPoolsMockRecorder) ID

                                                                                                                                                                                                                          ID indicates an expected call of ID

                                                                                                                                                                                                                          func (*MockIteratorPoolsMockRecorder) MultiReaderIterator

                                                                                                                                                                                                                          func (mr *MockIteratorPoolsMockRecorder) MultiReaderIterator() *gomock.Call

                                                                                                                                                                                                                            MultiReaderIterator indicates an expected call of MultiReaderIterator

                                                                                                                                                                                                                            func (*MockIteratorPoolsMockRecorder) MultiReaderIteratorArray

                                                                                                                                                                                                                            func (mr *MockIteratorPoolsMockRecorder) MultiReaderIteratorArray() *gomock.Call

                                                                                                                                                                                                                              MultiReaderIteratorArray indicates an expected call of MultiReaderIteratorArray

                                                                                                                                                                                                                              func (*MockIteratorPoolsMockRecorder) MutableSeriesIterators

                                                                                                                                                                                                                              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

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

                                                                                                                                                                                                                                    TagDecoder indicates an expected call of TagDecoder

                                                                                                                                                                                                                                    func (*MockIteratorPoolsMockRecorder) TagEncoder

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

                                                                                                                                                                                                                                      TagEncoder indicates an expected call of TagEncoder

                                                                                                                                                                                                                                      type MockMultiReaderIterator

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

                                                                                                                                                                                                                                        MockMultiReaderIterator is a mock of MultiReaderIterator interface

                                                                                                                                                                                                                                        func NewMockMultiReaderIterator

                                                                                                                                                                                                                                        func NewMockMultiReaderIterator(ctrl *gomock.Controller) *MockMultiReaderIterator

                                                                                                                                                                                                                                          NewMockMultiReaderIterator creates a new mock instance

                                                                                                                                                                                                                                          func (*MockMultiReaderIterator) Close

                                                                                                                                                                                                                                          func (m *MockMultiReaderIterator) Close()

                                                                                                                                                                                                                                            Close mocks base method

                                                                                                                                                                                                                                            func (*MockMultiReaderIterator) Current

                                                                                                                                                                                                                                              Current mocks base method

                                                                                                                                                                                                                                              func (*MockMultiReaderIterator) EXPECT

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

                                                                                                                                                                                                                                                func (*MockMultiReaderIterator) Err

                                                                                                                                                                                                                                                func (m *MockMultiReaderIterator) Err() error

                                                                                                                                                                                                                                                  Err mocks base method

                                                                                                                                                                                                                                                  func (*MockMultiReaderIterator) Next

                                                                                                                                                                                                                                                  func (m *MockMultiReaderIterator) Next() bool

                                                                                                                                                                                                                                                    Next mocks base method

                                                                                                                                                                                                                                                    func (*MockMultiReaderIterator) Readers

                                                                                                                                                                                                                                                      Readers mocks base method

                                                                                                                                                                                                                                                      func (*MockMultiReaderIterator) Reset

                                                                                                                                                                                                                                                      func (m *MockMultiReaderIterator) Reset(readers []xio.SegmentReader, start time.Time, blockSize time.Duration, schema namespace.SchemaDescr)

                                                                                                                                                                                                                                                        Reset mocks base method

                                                                                                                                                                                                                                                        func (*MockMultiReaderIterator) ResetSliceOfSlices

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

                                                                                                                                                                                                                                                          ResetSliceOfSlices mocks base method

                                                                                                                                                                                                                                                          func (*MockMultiReaderIterator) Schema

                                                                                                                                                                                                                                                            Schema mocks base method

                                                                                                                                                                                                                                                            type MockMultiReaderIteratorArrayPool

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

                                                                                                                                                                                                                                                              MockMultiReaderIteratorArrayPool is a mock of MultiReaderIteratorArrayPool interface

                                                                                                                                                                                                                                                              func NewMockMultiReaderIteratorArrayPool

                                                                                                                                                                                                                                                              func NewMockMultiReaderIteratorArrayPool(ctrl *gomock.Controller) *MockMultiReaderIteratorArrayPool

                                                                                                                                                                                                                                                                NewMockMultiReaderIteratorArrayPool creates a new mock instance

                                                                                                                                                                                                                                                                func (*MockMultiReaderIteratorArrayPool) EXPECT

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

                                                                                                                                                                                                                                                                  func (*MockMultiReaderIteratorArrayPool) Get

                                                                                                                                                                                                                                                                    Get mocks base method

                                                                                                                                                                                                                                                                    func (*MockMultiReaderIteratorArrayPool) Init

                                                                                                                                                                                                                                                                      Init mocks base method

                                                                                                                                                                                                                                                                      func (*MockMultiReaderIteratorArrayPool) Put

                                                                                                                                                                                                                                                                        Put mocks base method

                                                                                                                                                                                                                                                                        type MockMultiReaderIteratorArrayPoolMockRecorder

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

                                                                                                                                                                                                                                                                          MockMultiReaderIteratorArrayPoolMockRecorder is the mock recorder for MockMultiReaderIteratorArrayPool

                                                                                                                                                                                                                                                                          func (*MockMultiReaderIteratorArrayPoolMockRecorder) Get

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

                                                                                                                                                                                                                                                                            Get indicates an expected call of Get

                                                                                                                                                                                                                                                                            func (*MockMultiReaderIteratorArrayPoolMockRecorder) Init

                                                                                                                                                                                                                                                                              Init indicates an expected call of Init

                                                                                                                                                                                                                                                                              func (*MockMultiReaderIteratorArrayPoolMockRecorder) Put

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

                                                                                                                                                                                                                                                                                Put indicates an expected call of Put

                                                                                                                                                                                                                                                                                type MockMultiReaderIteratorMockRecorder

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

                                                                                                                                                                                                                                                                                  MockMultiReaderIteratorMockRecorder is the mock recorder for MockMultiReaderIterator

                                                                                                                                                                                                                                                                                  func (*MockMultiReaderIteratorMockRecorder) Close

                                                                                                                                                                                                                                                                                    Close indicates an expected call of Close

                                                                                                                                                                                                                                                                                    func (*MockMultiReaderIteratorMockRecorder) Current

                                                                                                                                                                                                                                                                                      Current indicates an expected call of Current

                                                                                                                                                                                                                                                                                      func (*MockMultiReaderIteratorMockRecorder) Err

                                                                                                                                                                                                                                                                                        Err indicates an expected call of Err

                                                                                                                                                                                                                                                                                        func (*MockMultiReaderIteratorMockRecorder) Next

                                                                                                                                                                                                                                                                                          Next indicates an expected call of Next

                                                                                                                                                                                                                                                                                          func (*MockMultiReaderIteratorMockRecorder) Readers

                                                                                                                                                                                                                                                                                            Readers indicates an expected call of Readers

                                                                                                                                                                                                                                                                                            func (*MockMultiReaderIteratorMockRecorder) Reset

                                                                                                                                                                                                                                                                                            func (mr *MockMultiReaderIteratorMockRecorder) Reset(readers, start, blockSize, schema interface{}) *gomock.Call

                                                                                                                                                                                                                                                                                              Reset indicates an expected call of Reset

                                                                                                                                                                                                                                                                                              func (*MockMultiReaderIteratorMockRecorder) ResetSliceOfSlices

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

                                                                                                                                                                                                                                                                                                ResetSliceOfSlices indicates an expected call of ResetSliceOfSlices

                                                                                                                                                                                                                                                                                                func (*MockMultiReaderIteratorMockRecorder) Schema

                                                                                                                                                                                                                                                                                                  Schema indicates an expected call of Schema

                                                                                                                                                                                                                                                                                                  type MockMultiReaderIteratorPool

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

                                                                                                                                                                                                                                                                                                    MockMultiReaderIteratorPool is a mock of MultiReaderIteratorPool interface

                                                                                                                                                                                                                                                                                                    func NewMockMultiReaderIteratorPool

                                                                                                                                                                                                                                                                                                    func NewMockMultiReaderIteratorPool(ctrl *gomock.Controller) *MockMultiReaderIteratorPool

                                                                                                                                                                                                                                                                                                      NewMockMultiReaderIteratorPool creates a new mock instance

                                                                                                                                                                                                                                                                                                      func (*MockMultiReaderIteratorPool) EXPECT

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

                                                                                                                                                                                                                                                                                                        func (*MockMultiReaderIteratorPool) Get

                                                                                                                                                                                                                                                                                                          Get mocks base method

                                                                                                                                                                                                                                                                                                          func (*MockMultiReaderIteratorPool) Init

                                                                                                                                                                                                                                                                                                            Init mocks base method

                                                                                                                                                                                                                                                                                                            func (*MockMultiReaderIteratorPool) Put

                                                                                                                                                                                                                                                                                                              Put mocks base method

                                                                                                                                                                                                                                                                                                              type MockMultiReaderIteratorPoolMockRecorder

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

                                                                                                                                                                                                                                                                                                                MockMultiReaderIteratorPoolMockRecorder is the mock recorder for MockMultiReaderIteratorPool

                                                                                                                                                                                                                                                                                                                func (*MockMultiReaderIteratorPoolMockRecorder) Get

                                                                                                                                                                                                                                                                                                                  Get indicates an expected call of Get

                                                                                                                                                                                                                                                                                                                  func (*MockMultiReaderIteratorPoolMockRecorder) Init

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

                                                                                                                                                                                                                                                                                                                    Init indicates an expected call of Init

                                                                                                                                                                                                                                                                                                                    func (*MockMultiReaderIteratorPoolMockRecorder) Put

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

                                                                                                                                                                                                                                                                                                                      Put indicates an expected call of Put

                                                                                                                                                                                                                                                                                                                      type MockMutableSeriesIterators

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

                                                                                                                                                                                                                                                                                                                        MockMutableSeriesIterators is a mock of MutableSeriesIterators interface

                                                                                                                                                                                                                                                                                                                        func NewMockMutableSeriesIterators

                                                                                                                                                                                                                                                                                                                        func NewMockMutableSeriesIterators(ctrl *gomock.Controller) *MockMutableSeriesIterators

                                                                                                                                                                                                                                                                                                                          NewMockMutableSeriesIterators creates a new mock instance

                                                                                                                                                                                                                                                                                                                          func (*MockMutableSeriesIterators) Cap

                                                                                                                                                                                                                                                                                                                            Cap mocks base method

                                                                                                                                                                                                                                                                                                                            func (*MockMutableSeriesIterators) Close

                                                                                                                                                                                                                                                                                                                            func (m *MockMutableSeriesIterators) Close()

                                                                                                                                                                                                                                                                                                                              Close mocks base method

                                                                                                                                                                                                                                                                                                                              func (*MockMutableSeriesIterators) EXPECT

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

                                                                                                                                                                                                                                                                                                                                func (*MockMutableSeriesIterators) Iters

                                                                                                                                                                                                                                                                                                                                  Iters mocks base method

                                                                                                                                                                                                                                                                                                                                  func (*MockMutableSeriesIterators) Len

                                                                                                                                                                                                                                                                                                                                    Len mocks base method

                                                                                                                                                                                                                                                                                                                                    func (*MockMutableSeriesIterators) Reset

                                                                                                                                                                                                                                                                                                                                    func (m *MockMutableSeriesIterators) Reset(size int)

                                                                                                                                                                                                                                                                                                                                      Reset mocks base method

                                                                                                                                                                                                                                                                                                                                      func (*MockMutableSeriesIterators) SetAt

                                                                                                                                                                                                                                                                                                                                      func (m *MockMutableSeriesIterators) SetAt(idx int, iter SeriesIterator)

                                                                                                                                                                                                                                                                                                                                        SetAt mocks base method

                                                                                                                                                                                                                                                                                                                                        type MockMutableSeriesIteratorsMockRecorder

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

                                                                                                                                                                                                                                                                                                                                          MockMutableSeriesIteratorsMockRecorder is the mock recorder for MockMutableSeriesIterators

                                                                                                                                                                                                                                                                                                                                          func (*MockMutableSeriesIteratorsMockRecorder) Cap

                                                                                                                                                                                                                                                                                                                                            Cap indicates an expected call of Cap

                                                                                                                                                                                                                                                                                                                                            func (*MockMutableSeriesIteratorsMockRecorder) Close

                                                                                                                                                                                                                                                                                                                                              Close indicates an expected call of Close

                                                                                                                                                                                                                                                                                                                                              func (*MockMutableSeriesIteratorsMockRecorder) Iters

                                                                                                                                                                                                                                                                                                                                                Iters indicates an expected call of Iters

                                                                                                                                                                                                                                                                                                                                                func (*MockMutableSeriesIteratorsMockRecorder) Len

                                                                                                                                                                                                                                                                                                                                                  Len indicates an expected call of Len

                                                                                                                                                                                                                                                                                                                                                  func (*MockMutableSeriesIteratorsMockRecorder) Reset

                                                                                                                                                                                                                                                                                                                                                  func (mr *MockMutableSeriesIteratorsMockRecorder) Reset(size interface{}) *gomock.Call

                                                                                                                                                                                                                                                                                                                                                    Reset indicates an expected call of Reset

                                                                                                                                                                                                                                                                                                                                                    func (*MockMutableSeriesIteratorsMockRecorder) SetAt

                                                                                                                                                                                                                                                                                                                                                    func (mr *MockMutableSeriesIteratorsMockRecorder) SetAt(idx, iter interface{}) *gomock.Call

                                                                                                                                                                                                                                                                                                                                                      SetAt indicates an expected call of SetAt

                                                                                                                                                                                                                                                                                                                                                      type MockMutableSeriesIteratorsPool

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

                                                                                                                                                                                                                                                                                                                                                        MockMutableSeriesIteratorsPool is a mock of MutableSeriesIteratorsPool interface

                                                                                                                                                                                                                                                                                                                                                        func NewMockMutableSeriesIteratorsPool

                                                                                                                                                                                                                                                                                                                                                        func NewMockMutableSeriesIteratorsPool(ctrl *gomock.Controller) *MockMutableSeriesIteratorsPool

                                                                                                                                                                                                                                                                                                                                                          NewMockMutableSeriesIteratorsPool creates a new mock instance

                                                                                                                                                                                                                                                                                                                                                          func (*MockMutableSeriesIteratorsPool) EXPECT

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

                                                                                                                                                                                                                                                                                                                                                            func (*MockMutableSeriesIteratorsPool) Get

                                                                                                                                                                                                                                                                                                                                                              Get mocks base method

                                                                                                                                                                                                                                                                                                                                                              func (*MockMutableSeriesIteratorsPool) Init

                                                                                                                                                                                                                                                                                                                                                                Init mocks base method

                                                                                                                                                                                                                                                                                                                                                                func (*MockMutableSeriesIteratorsPool) Put

                                                                                                                                                                                                                                                                                                                                                                  Put mocks base method

                                                                                                                                                                                                                                                                                                                                                                  type MockMutableSeriesIteratorsPoolMockRecorder

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

                                                                                                                                                                                                                                                                                                                                                                    MockMutableSeriesIteratorsPoolMockRecorder is the mock recorder for MockMutableSeriesIteratorsPool

                                                                                                                                                                                                                                                                                                                                                                    func (*MockMutableSeriesIteratorsPoolMockRecorder) Get

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

                                                                                                                                                                                                                                                                                                                                                                      Get indicates an expected call of Get

                                                                                                                                                                                                                                                                                                                                                                      func (*MockMutableSeriesIteratorsPoolMockRecorder) Init

                                                                                                                                                                                                                                                                                                                                                                        Init indicates an expected call of Init

                                                                                                                                                                                                                                                                                                                                                                        func (*MockMutableSeriesIteratorsPoolMockRecorder) Put

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

                                                                                                                                                                                                                                                                                                                                                                          Put indicates an expected call of Put

                                                                                                                                                                                                                                                                                                                                                                          type MockOStream

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

                                                                                                                                                                                                                                                                                                                                                                            MockOStream is a mock of OStream interface

                                                                                                                                                                                                                                                                                                                                                                            func NewMockOStream

                                                                                                                                                                                                                                                                                                                                                                            func NewMockOStream(ctrl *gomock.Controller) *MockOStream

                                                                                                                                                                                                                                                                                                                                                                              NewMockOStream creates a new mock instance

                                                                                                                                                                                                                                                                                                                                                                              func (*MockOStream) CheckedBytes

                                                                                                                                                                                                                                                                                                                                                                              func (m *MockOStream) CheckedBytes() (checked.Bytes, int)

                                                                                                                                                                                                                                                                                                                                                                                CheckedBytes mocks base method

                                                                                                                                                                                                                                                                                                                                                                                func (*MockOStream) Discard

                                                                                                                                                                                                                                                                                                                                                                                func (m *MockOStream) Discard() checked.Bytes

                                                                                                                                                                                                                                                                                                                                                                                  Discard mocks base method

                                                                                                                                                                                                                                                                                                                                                                                  func (*MockOStream) EXPECT

                                                                                                                                                                                                                                                                                                                                                                                  func (m *MockOStream) EXPECT() *MockOStreamMockRecorder

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

                                                                                                                                                                                                                                                                                                                                                                                    func (*MockOStream) Empty

                                                                                                                                                                                                                                                                                                                                                                                    func (m *MockOStream) Empty() bool

                                                                                                                                                                                                                                                                                                                                                                                      Empty mocks base method

                                                                                                                                                                                                                                                                                                                                                                                      func (*MockOStream) Len

                                                                                                                                                                                                                                                                                                                                                                                      func (m *MockOStream) Len() int

                                                                                                                                                                                                                                                                                                                                                                                        Len mocks base method

                                                                                                                                                                                                                                                                                                                                                                                        func (*MockOStream) RawBytes

                                                                                                                                                                                                                                                                                                                                                                                        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

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

                                                                                                                                                                                                                                                                                                                                                                                              Write mocks base method

                                                                                                                                                                                                                                                                                                                                                                                              func (*MockOStream) WriteBit

                                                                                                                                                                                                                                                                                                                                                                                              func (m *MockOStream) WriteBit(v Bit)

                                                                                                                                                                                                                                                                                                                                                                                                WriteBit mocks base method

                                                                                                                                                                                                                                                                                                                                                                                                func (*MockOStream) WriteBits

                                                                                                                                                                                                                                                                                                                                                                                                func (m *MockOStream) WriteBits(v uint64, numBits int)

                                                                                                                                                                                                                                                                                                                                                                                                  WriteBits mocks base method

                                                                                                                                                                                                                                                                                                                                                                                                  func (*MockOStream) WriteByte

                                                                                                                                                                                                                                                                                                                                                                                                  func (m *MockOStream) WriteByte(v byte)

                                                                                                                                                                                                                                                                                                                                                                                                    WriteByte mocks base method

                                                                                                                                                                                                                                                                                                                                                                                                    func (*MockOStream) WriteBytes

                                                                                                                                                                                                                                                                                                                                                                                                    func (m *MockOStream) WriteBytes(bytes []byte)

                                                                                                                                                                                                                                                                                                                                                                                                      WriteBytes mocks base method

                                                                                                                                                                                                                                                                                                                                                                                                      type MockOStreamMockRecorder

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

                                                                                                                                                                                                                                                                                                                                                                                                        MockOStreamMockRecorder is the mock recorder for MockOStream

                                                                                                                                                                                                                                                                                                                                                                                                        func (*MockOStreamMockRecorder) CheckedBytes

                                                                                                                                                                                                                                                                                                                                                                                                        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

                                                                                                                                                                                                                                                                                                                                                                                                                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

                                                                                                                                                                                                                                                                                                                                                                                                                    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

                                                                                                                                                                                                                                                                                                                                                                                                                                  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

                                                                                                                                                                                                                                                                                                                                                                                                                                      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

                                                                                                                                                                                                                                                                                                                                                                                                                                              func (m *MockOptions) IStreamReaderSizeM3TSZ() int

                                                                                                                                                                                                                                                                                                                                                                                                                                                IStreamReaderSizeM3TSZ mocks base method

                                                                                                                                                                                                                                                                                                                                                                                                                                                func (*MockOptions) IStreamReaderSizeProto

                                                                                                                                                                                                                                                                                                                                                                                                                                                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

                                                                                                                                                                                                                                                                                                                                                                                                                                                        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

                                                                                                                                                                                                                                                                                                                                                                                                                                                            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

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

                                                                                                                                                                                                                                                                                                                                                                                                                                                                    SetIStreamReaderSizeM3TSZ mocks base method

                                                                                                                                                                                                                                                                                                                                                                                                                                                                    func (*MockOptions) SetIStreamReaderSizeProto

                                                                                                                                                                                                                                                                                                                                                                                                                                                                    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

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  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

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      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

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

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              IStreamReaderSizeM3TSZ indicates an expected call of IStreamReaderSizeM3TSZ

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              func (*MockOptionsMockRecorder) IStreamReaderSizeProto

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              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

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      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

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          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

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

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  SetIStreamReaderSizeM3TSZ indicates an expected call of SetIStreamReaderSizeM3TSZ

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  func (*MockOptionsMockRecorder) SetIStreamReaderSizeProto

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

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    SetIStreamReaderSizeProto indicates an expected call of SetIStreamReaderSizeProto

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    func (*MockOptionsMockRecorder) SetMarkerEncodingScheme

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

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      SetMarkerEncodingScheme indicates an expected call of SetMarkerEncodingScheme

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      func (*MockOptionsMockRecorder) SetReaderIteratorPool

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

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        SetReaderIteratorPool indicates an expected call of SetReaderIteratorPool

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        func (*MockOptionsMockRecorder) SetSegmentReaderPool

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

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          SetSegmentReaderPool indicates an expected call of SetSegmentReaderPool

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          func (*MockOptionsMockRecorder) SetTimeEncodingSchemes

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

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                            SetTimeEncodingSchemes indicates an expected call of SetTimeEncodingSchemes

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                            func (*MockOptionsMockRecorder) TimeEncodingSchemes

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

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              TimeEncodingSchemes indicates an expected call of TimeEncodingSchemes

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              type MockReaderIterator

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

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                MockReaderIterator is a mock of ReaderIterator interface

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                func NewMockReaderIterator

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                func NewMockReaderIterator(ctrl *gomock.Controller) *MockReaderIterator

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  NewMockReaderIterator creates a new mock instance

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  func (*MockReaderIterator) Close

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  func (m *MockReaderIterator) Close()

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    Close mocks base method

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    func (*MockReaderIterator) Current

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      Current mocks base method

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      func (*MockReaderIterator) EXPECT

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

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        func (*MockReaderIterator) Err

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        func (m *MockReaderIterator) Err() error

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          Err mocks base method

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          func (*MockReaderIterator) Next

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          func (m *MockReaderIterator) Next() bool

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                            Next mocks base method

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                            func (*MockReaderIterator) Reset

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                            func (m *MockReaderIterator) Reset(reader io.Reader, schema namespace.SchemaDescr)

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              Reset mocks base method

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              type MockReaderIteratorMockRecorder

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

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                MockReaderIteratorMockRecorder is the mock recorder for MockReaderIterator

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                func (*MockReaderIteratorMockRecorder) Close

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  Close indicates an expected call of Close

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  func (*MockReaderIteratorMockRecorder) Current

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    Current indicates an expected call of Current

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    func (*MockReaderIteratorMockRecorder) Err

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      Err indicates an expected call of Err

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      func (*MockReaderIteratorMockRecorder) Next

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        Next indicates an expected call of Next

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        func (*MockReaderIteratorMockRecorder) Reset

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        func (mr *MockReaderIteratorMockRecorder) Reset(reader, schema interface{}) *gomock.Call

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          Reset indicates an expected call of Reset

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          type MockReaderIteratorPool

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

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                            MockReaderIteratorPool is a mock of ReaderIteratorPool interface

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                            func NewMockReaderIteratorPool

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                            func NewMockReaderIteratorPool(ctrl *gomock.Controller) *MockReaderIteratorPool

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              NewMockReaderIteratorPool creates a new mock instance

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              func (*MockReaderIteratorPool) EXPECT

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

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                func (*MockReaderIteratorPool) Get

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  Get mocks base method

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  func (*MockReaderIteratorPool) Init

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    Init mocks base method

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    func (*MockReaderIteratorPool) Put

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      Put mocks base method

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      type MockReaderIteratorPoolMockRecorder

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

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        MockReaderIteratorPoolMockRecorder is the mock recorder for MockReaderIteratorPool

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        func (*MockReaderIteratorPoolMockRecorder) Get

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          Get indicates an expected call of Get

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          func (*MockReaderIteratorPoolMockRecorder) Init

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

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                            Init indicates an expected call of Init

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                            func (*MockReaderIteratorPoolMockRecorder) Put

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

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              Put indicates an expected call of Put

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              type MockSeriesIterator

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

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                MockSeriesIterator is a mock of SeriesIterator interface

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                func NewMockSeriesIterator

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                func NewMockSeriesIterator(ctrl *gomock.Controller) *MockSeriesIterator

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  NewMockSeriesIterator creates a new mock instance

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  func (*MockSeriesIterator) Close

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  func (m *MockSeriesIterator) Close()

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    Close mocks base method

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    func (*MockSeriesIterator) Current

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      Current mocks base method

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      func (*MockSeriesIterator) EXPECT

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

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        func (*MockSeriesIterator) End

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        func (m *MockSeriesIterator) End() time.Time

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          End mocks base method

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          func (*MockSeriesIterator) Err

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          func (m *MockSeriesIterator) Err() error

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                            Err mocks base method

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                            func (*MockSeriesIterator) ID

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                            func (m *MockSeriesIterator) ID() ident.ID

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              ID mocks base method

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              func (*MockSeriesIterator) Namespace

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              func (m *MockSeriesIterator) Namespace() ident.ID

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                Namespace mocks base method

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                func (*MockSeriesIterator) Next

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                func (m *MockSeriesIterator) Next() bool

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  Next mocks base method

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  func (*MockSeriesIterator) Replicas

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  func (m *MockSeriesIterator) Replicas() ([]MultiReaderIterator, error)

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    Replicas mocks base method

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    func (*MockSeriesIterator) Reset

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      Reset mocks base method

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      func (*MockSeriesIterator) SetIterateEqualTimestampStrategy

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      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

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                            Stats mocks base method

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                            func (*MockSeriesIterator) Tags

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              Tags mocks base method

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              type MockSeriesIteratorAccumulator

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

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                MockSeriesIteratorAccumulator is a mock of SeriesIteratorAccumulator interface

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                func NewMockSeriesIteratorAccumulator

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                func NewMockSeriesIteratorAccumulator(ctrl *gomock.Controller) *MockSeriesIteratorAccumulator

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  NewMockSeriesIteratorAccumulator creates a new mock instance

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  func (*MockSeriesIteratorAccumulator) Add

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    Add mocks base method

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    func (*MockSeriesIteratorAccumulator) Close

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    func (m *MockSeriesIteratorAccumulator) Close()

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      Close mocks base method

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      func (*MockSeriesIteratorAccumulator) Current

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        Current mocks base method

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        func (*MockSeriesIteratorAccumulator) EXPECT

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

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          func (*MockSeriesIteratorAccumulator) End

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                            End mocks base method

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                            func (*MockSeriesIteratorAccumulator) Err

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              Err mocks base method

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              func (*MockSeriesIteratorAccumulator) ID

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                ID mocks base method

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                func (*MockSeriesIteratorAccumulator) Namespace

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                func (m *MockSeriesIteratorAccumulator) Namespace() ident.ID

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  Namespace mocks base method

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  func (*MockSeriesIteratorAccumulator) Next

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    Next mocks base method

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    func (*MockSeriesIteratorAccumulator) Replicas

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      Replicas mocks base method

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      func (*MockSeriesIteratorAccumulator) Reset

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        Reset mocks base method

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        func (*MockSeriesIteratorAccumulator) SetIterateEqualTimestampStrategy

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        func (m *MockSeriesIteratorAccumulator) SetIterateEqualTimestampStrategy(strategy IterateEqualTimestampStrategy)

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          SetIterateEqualTimestampStrategy mocks base method

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          func (*MockSeriesIteratorAccumulator) Start

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                            Start mocks base method

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                            func (*MockSeriesIteratorAccumulator) Stats

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              Stats mocks base method

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              func (*MockSeriesIteratorAccumulator) Tags

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                Tags mocks base method

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                type MockSeriesIteratorAccumulatorMockRecorder

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

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  MockSeriesIteratorAccumulatorMockRecorder is the mock recorder for MockSeriesIteratorAccumulator

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  func (*MockSeriesIteratorAccumulatorMockRecorder) Add

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  func (mr *MockSeriesIteratorAccumulatorMockRecorder) Add(it interface{}) *gomock.Call

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    Add indicates an expected call of Add

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    func (*MockSeriesIteratorAccumulatorMockRecorder) Close

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      Close indicates an expected call of Close

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      func (*MockSeriesIteratorAccumulatorMockRecorder) Current

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        Current indicates an expected call of Current

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        func (*MockSeriesIteratorAccumulatorMockRecorder) End

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          End indicates an expected call of End

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          func (*MockSeriesIteratorAccumulatorMockRecorder) Err

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                            Err indicates an expected call of Err

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                            func (*MockSeriesIteratorAccumulatorMockRecorder) ID

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              ID indicates an expected call of ID

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              func (*MockSeriesIteratorAccumulatorMockRecorder) Namespace

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                Namespace indicates an expected call of Namespace

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                func (*MockSeriesIteratorAccumulatorMockRecorder) Next

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  Next indicates an expected call of Next

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  func (*MockSeriesIteratorAccumulatorMockRecorder) Replicas

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    Replicas indicates an expected call of Replicas

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    func (*MockSeriesIteratorAccumulatorMockRecorder) Reset

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    func (mr *MockSeriesIteratorAccumulatorMockRecorder) Reset(opts interface{}) *gomock.Call

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      Reset indicates an expected call of Reset

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      func (*MockSeriesIteratorAccumulatorMockRecorder) SetIterateEqualTimestampStrategy

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

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        SetIterateEqualTimestampStrategy indicates an expected call of SetIterateEqualTimestampStrategy

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        func (*MockSeriesIteratorAccumulatorMockRecorder) Start

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          Start indicates an expected call of Start

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          func (*MockSeriesIteratorAccumulatorMockRecorder) Stats

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                            Stats indicates an expected call of Stats

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                            func (*MockSeriesIteratorAccumulatorMockRecorder) Tags

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              Tags indicates an expected call of Tags

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              type MockSeriesIteratorConsolidator

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

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                MockSeriesIteratorConsolidator is a mock of SeriesIteratorConsolidator interface

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                func NewMockSeriesIteratorConsolidator

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                func NewMockSeriesIteratorConsolidator(ctrl *gomock.Controller) *MockSeriesIteratorConsolidator

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  NewMockSeriesIteratorConsolidator creates a new mock instance

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  func (*MockSeriesIteratorConsolidator) ConsolidateReplicas

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  func (m *MockSeriesIteratorConsolidator) ConsolidateReplicas(replicas []MultiReaderIterator) ([]MultiReaderIterator, error)

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    ConsolidateReplicas mocks base method

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    func (*MockSeriesIteratorConsolidator) EXPECT

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

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      type MockSeriesIteratorConsolidatorMockRecorder

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

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        MockSeriesIteratorConsolidatorMockRecorder is the mock recorder for MockSeriesIteratorConsolidator

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        func (*MockSeriesIteratorConsolidatorMockRecorder) ConsolidateReplicas

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        func (mr *MockSeriesIteratorConsolidatorMockRecorder) ConsolidateReplicas(replicas interface{}) *gomock.Call

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          ConsolidateReplicas indicates an expected call of ConsolidateReplicas

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          type MockSeriesIteratorMockRecorder

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

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                            MockSeriesIteratorMockRecorder is the mock recorder for MockSeriesIterator

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                            func (*MockSeriesIteratorMockRecorder) Close

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              Close indicates an expected call of Close

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              func (*MockSeriesIteratorMockRecorder) Current

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                Current indicates an expected call of Current

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                func (*MockSeriesIteratorMockRecorder) End

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  End indicates an expected call of End

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  func (*MockSeriesIteratorMockRecorder) Err

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    Err indicates an expected call of Err

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    func (*MockSeriesIteratorMockRecorder) ID

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      ID indicates an expected call of ID

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      func (*MockSeriesIteratorMockRecorder) Namespace

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      func (mr *MockSeriesIteratorMockRecorder) Namespace() *gomock.Call

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        Namespace indicates an expected call of Namespace

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        func (*MockSeriesIteratorMockRecorder) Next

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          Next indicates an expected call of Next

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          func (*MockSeriesIteratorMockRecorder) Replicas

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          func (mr *MockSeriesIteratorMockRecorder) Replicas() *gomock.Call

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                            Replicas indicates an expected call of Replicas

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                            func (*MockSeriesIteratorMockRecorder) Reset

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                            func (mr *MockSeriesIteratorMockRecorder) Reset(opts interface{}) *gomock.Call

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              Reset indicates an expected call of Reset

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              func (*MockSeriesIteratorMockRecorder) SetIterateEqualTimestampStrategy

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

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                SetIterateEqualTimestampStrategy indicates an expected call of SetIterateEqualTimestampStrategy

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                func (*MockSeriesIteratorMockRecorder) Start

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  Start indicates an expected call of Start

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  func (*MockSeriesIteratorMockRecorder) Stats

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    Stats indicates an expected call of Stats

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    func (*MockSeriesIteratorMockRecorder) Tags

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      Tags indicates an expected call of Tags

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      type MockSeriesIteratorPool

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

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        MockSeriesIteratorPool is a mock of SeriesIteratorPool interface

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        func NewMockSeriesIteratorPool

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        func NewMockSeriesIteratorPool(ctrl *gomock.Controller) *MockSeriesIteratorPool

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          NewMockSeriesIteratorPool creates a new mock instance

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          func (*MockSeriesIteratorPool) EXPECT

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

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                            func (*MockSeriesIteratorPool) Get

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              Get mocks base method

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              func (*MockSeriesIteratorPool) Init

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              func (m *MockSeriesIteratorPool) Init()

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                Init mocks base method

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                func (*MockSeriesIteratorPool) Put

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  Put mocks base method

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  type MockSeriesIteratorPoolMockRecorder

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

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    MockSeriesIteratorPoolMockRecorder is the mock recorder for MockSeriesIteratorPool

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    func (*MockSeriesIteratorPoolMockRecorder) Get

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      Get indicates an expected call of Get

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      func (*MockSeriesIteratorPoolMockRecorder) Init

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        Init indicates an expected call of Init

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        func (*MockSeriesIteratorPoolMockRecorder) Put

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

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          Put indicates an expected call of Put

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          type MockSeriesIterators

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

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                            MockSeriesIterators is a mock of SeriesIterators interface

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                            func NewMockSeriesIterators

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                            func NewMockSeriesIterators(ctrl *gomock.Controller) *MockSeriesIterators

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              NewMockSeriesIterators creates a new mock instance

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              func (*MockSeriesIterators) Close

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              func (m *MockSeriesIterators) Close()

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                Close mocks base method

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                func (*MockSeriesIterators) EXPECT

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

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  func (*MockSeriesIterators) Iters

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

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    Iters mocks base method

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    func (*MockSeriesIterators) Len

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    func (m *MockSeriesIterators) Len() int

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      Len mocks base method

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      type MockSeriesIteratorsMockRecorder

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

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        MockSeriesIteratorsMockRecorder is the mock recorder for MockSeriesIterators

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        func (*MockSeriesIteratorsMockRecorder) Close

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          Close indicates an expected call of Close

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          func (*MockSeriesIteratorsMockRecorder) Iters

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                            Iters indicates an expected call of Iters

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                            func (*MockSeriesIteratorsMockRecorder) Len

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              Len indicates an expected call of Len

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              type MultiReaderIterator

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              type MultiReaderIterator interface {
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              	Iterator
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              	// Reset resets the iterator to read from a slice of readers
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              	// with a new schema (for schema aware iterators).
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              	Reset(readers []xio.SegmentReader, start time.Time,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              		blockSize time.Duration, schema namespace.SchemaDescr)
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              	// Reset resets the iterator to read from a slice of slice readers
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              	// with a new schema (for schema aware iterators).
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              	ResetSliceOfSlices(
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              		readers xio.ReaderSliceOfSlicesIterator,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              		schema namespace.SchemaDescr,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              	)
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              	// Readers exposes the underlying ReaderSliceOfSlicesIterator
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              	// for this MultiReaderIterator.
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              	Readers() xio.ReaderSliceOfSlicesIterator
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              	// Schema exposes the underlying SchemaDescr for this MultiReaderIterator.
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              	Schema() namespace.SchemaDescr
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              }

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

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                func NewMultiReaderIterator

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                func NewMultiReaderIterator(
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                	iteratorAlloc ReaderIteratorAllocate,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                	pool MultiReaderIteratorPool,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                ) MultiReaderIterator

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  NewMultiReaderIterator creates a new multi-reader iterator.

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  type MultiReaderIteratorArrayPool

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  type MultiReaderIteratorArrayPool interface {
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  	// Init initializes the pool.
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  	Init()
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  	// Get provides a MultiReaderIterator array from the pool.
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  	Get(size int) []MultiReaderIterator
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  	// Put returns a MultiReaderIterator array to the pool.
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  	Put(iters []MultiReaderIterator)
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  }

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    MultiReaderIteratorArrayPool provides a pool for MultiReaderIterator arrays.

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    func NewMultiReaderIteratorArrayPool

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    func NewMultiReaderIteratorArrayPool(sizes []pool.Bucket) MultiReaderIteratorArrayPool

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      NewMultiReaderIteratorArrayPool creates a new pool

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      type MultiReaderIteratorPool

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      type MultiReaderIteratorPool interface {
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      	// Init initializes the pool.
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      	Init(alloc ReaderIteratorAllocate)
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      	// Get provides a MultiReaderIterator from the pool.
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      	Get() MultiReaderIterator
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      	// Put returns a MultiReaderIterator to the pool.
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      	Put(iter MultiReaderIterator)
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      }

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        MultiReaderIteratorPool provides a pool for MultiReaderIterators.

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        func NewMultiReaderIteratorPool

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        func NewMultiReaderIteratorPool(opts pool.ObjectPoolOptions) MultiReaderIteratorPool

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          NewMultiReaderIteratorPool creates a new pool for MultiReaderIterators.

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          type MutableSeriesIterators

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          type MutableSeriesIterators interface {
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          	SeriesIterators
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          	// Reset the iters collection to a size for reuse.
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          	Reset(size int)
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          	// Cap returns the capacity of the iters.
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          	Cap() int
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          	// SetAt sets a SeriesIterator to the given index.
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          	SetAt(idx int, iter SeriesIterator)
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          }

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                            MutableSeriesIterators is a mutable SeriesIterators.

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                            func NewSeriesIterators

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

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              NewSeriesIterators creates a new series iterators collection

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              type MutableSeriesIteratorsPool

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              type MutableSeriesIteratorsPool interface {
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              	// Init initializes the pool.
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              	Init()
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              	// Get provides a MutableSeriesIterators from the pool.
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              	Get(size int) MutableSeriesIterators
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              	// Put returns a MutableSeriesIterators to the pool.
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              	Put(iters MutableSeriesIterators)
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              }

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                MutableSeriesIteratorsPool provides a pool for MutableSeriesIterators.

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                func NewMutableSeriesIteratorsPool

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                func NewMutableSeriesIteratorsPool(sizes []pool.Bucket) MutableSeriesIteratorsPool

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  NewMutableSeriesIteratorsPool creates a new pool

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  type NewDecoderFn

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  type NewDecoderFn func() Decoder

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    NewDecoderFn creates a new decoder.

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    type NewEncoderFn

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

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      NewEncoderFn creates a new encoder.

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      type OStream

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      type OStream interface {
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      	// Len returns the length of the OStream.
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      	Len() int
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      	// Empty returns whether the OStream is empty.
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      	Empty() bool
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      	// WriteBit writes the last bit of v.
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      	WriteBit(v Bit)
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      	// WriteBits writes the lowest numBits of v to the stream, starting
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      	// from the most significant bit to the least significant bit.
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      	WriteBits(v uint64, numBits int)
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      	// WriteByte writes the last byte of v.
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      	WriteByte(v byte)
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      	// WriteBytes writes a byte slice.
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      	WriteBytes(bytes []byte)
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      	// Write writes a byte slice. This method exists in addition to WriteBytes()
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      	// to satisfy the io.Writer interface.
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      	Write(bytes []byte) (int, error)
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      	// Reset resets the ostream.
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      	Reset(buffer checked.Bytes)
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      	// Discard takes the ref to the checked bytes from the OStream.
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      	Discard() checked.Bytes
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      	// RawBytes returns the OStream's raw bytes. Note that this does not transfer
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      	// ownership of the data and bypasses the checked.Bytes accounting so
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      	// callers should:
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      	//     1. Only use the returned slice as a "read-only" snapshot of the
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      	//        data in a context where the caller has at least a read lock
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      	//        on the ostream itself.
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      	//     2. Use this function with care.
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      	RawBytes() ([]byte, int)
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      	// CheckedBytes returns the written stream as checked bytes.
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      	CheckedBytes() (checked.Bytes, int)
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      }

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        OStream encapsulates a writable stream.

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        func NewOStream

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

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          NewOStream creates a new Ostream

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          type Options

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          type Options interface {
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          	// SetDefaultTimeUnit sets the default time unit for the encoder.
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          	SetDefaultTimeUnit(tu xtime.Unit) Options
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          	// DefaultTimeUnit returns the default time unit for the encoder.
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          	DefaultTimeUnit() xtime.Unit
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          	// SetTimeEncodingSchemes sets the time encoding schemes for different time units.
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          	SetTimeEncodingSchemes(value map[xtime.Unit]TimeEncodingScheme) Options
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          	// TimeEncodingSchemes returns the time encoding schemes for different time units.
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          	TimeEncodingSchemes() TimeEncodingSchemes
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          	// SetMarkerEncodingScheme sets the marker encoding scheme.
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          	SetMarkerEncodingScheme(value MarkerEncodingScheme) Options
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          	// MarkerEncodingScheme returns the marker encoding scheme.
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          	MarkerEncodingScheme() MarkerEncodingScheme
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          	// SetEncoderPool sets the encoder pool.
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          	SetEncoderPool(value EncoderPool) Options
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          	// EncoderPool returns the encoder pool.
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          	EncoderPool() EncoderPool
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          	// SetReaderIteratorPool sets the ReaderIteratorPool.
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          	SetReaderIteratorPool(value ReaderIteratorPool) Options
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          	// ReaderIteratorPool returns the ReaderIteratorPool.
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          	ReaderIteratorPool() ReaderIteratorPool
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          	// SetBytesPool sets the bytes pool.
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          	SetBytesPool(value pool.CheckedBytesPool) Options
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          	// BytesPool returns the bytes pool.
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          	BytesPool() pool.CheckedBytesPool
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          	// SetSegmentReaderPool sets the segment reader pool.
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          	SetSegmentReaderPool(value xio.SegmentReaderPool) Options
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          	// SegmentReaderPool returns the segment reader pool.
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          	SegmentReaderPool() xio.SegmentReaderPool
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          	// SetCheckedBytesWrapperPool sets the checked bytes wrapper pool.
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          	SetCheckedBytesWrapperPool(value xpool.CheckedBytesWrapperPool) Options
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          	// CheckedBytesWrapperPool returns the checked bytes wrapper pool.
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          	CheckedBytesWrapperPool() xpool.CheckedBytesWrapperPool
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          	// SetByteFieldDictionaryLRUSize sets theByteFieldDictionaryLRUSize which controls
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          	// how many recently seen byte field values will be maintained in the compression
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          	// dictionaries LRU when compressing / decompressing byte fields in ProtoBuf messages.
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          	// Increasing this value can potentially lead to better compression at the cost of
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          	// using more memory for storing metadata when compressing / decompressing.
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          	SetByteFieldDictionaryLRUSize(value int) Options
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          	// ByteFieldDictionaryLRUSize returns the ByteFieldDictionaryLRUSize.
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          	ByteFieldDictionaryLRUSize() int
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          	// SetIStreamReaderSizeM3TSZ sets the istream bufio reader size
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          	// for m3tsz encoding iteration.
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          	SetIStreamReaderSizeM3TSZ(value int) Options
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          	// IStreamReaderSizeM3TSZ returns the istream bufio reader size
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          	// for m3tsz encoding iteration.
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          	IStreamReaderSizeM3TSZ() int
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          	// SetIStreamReaderSizeProto sets the istream bufio reader size
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          	// for proto encoding iteration.
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          	SetIStreamReaderSizeProto(value int) Options
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          	// SetIStreamReaderSizeProto returns the istream bufio reader size
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          	// for proto encoding iteration.
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          	IStreamReaderSizeProto() int
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          }

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

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                            func NewOptions

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                            func NewOptions() Options

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              NewOptions creates a new options.

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              type ReaderIterator

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              type ReaderIterator interface {
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              	Iterator
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              	// Reset resets the iterator to read from a new reader with
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              	// a new schema (for schema aware iterators).
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              	Reset(reader io.Reader, schema namespace.SchemaDescr)
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              }

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                ReaderIterator is the interface for a single-reader iterator.

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                func NewNullReaderIterator

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                func NewNullReaderIterator() ReaderIterator

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  NewNullReaderIterator returns a new reader iterator that performs no operations

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  type ReaderIteratorAllocate

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  type ReaderIteratorAllocate func(reader io.Reader, descr namespace.SchemaDescr) ReaderIterator

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    ReaderIteratorAllocate allocates a ReaderIterator for a pool.

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    type ReaderIteratorPool

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    type ReaderIteratorPool interface {
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    	// Init initializes the pool.
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    	Init(alloc ReaderIteratorAllocate)
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    	// Get provides a ReaderIterator from the pool.
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    	Get() ReaderIterator
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    	// Put returns a ReaderIterator to the pool.
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    	Put(iter ReaderIterator)
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    }

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      ReaderIteratorPool provides a pool for ReaderIterators.

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      func NewReaderIteratorPool

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      func NewReaderIteratorPool(opts pool.ObjectPoolOptions) ReaderIteratorPool

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        NewReaderIteratorPool creates a new pool for ReaderIterators.

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        type SeriesAccumulatorOptions

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        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

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              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

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

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  NewSeriesIteratorAccumulator creates a new series iterator.

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  type SeriesIteratorConsolidator

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

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    SeriesIteratorConsolidator optionally defines methods to consolidate series iterators.

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    type SeriesIteratorOptions

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    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

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          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

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

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

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        Directories

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        Path Synopsis