index

Aug 23, 2019

Changes in this version

type QueryResultsOptions

+ FilterID func(id ident.ID) bool

Jun 8, 2019

Changes in this version

type MockOnIndexSeries

+ func (m *MockOnIndexSeries) NeedsIndexUpdate(indexBlockStartForWrite time0.UnixNano) bool

+ func (m *MockOnIndexSeries) OnIndexPrepare()

type MockOnIndexSeriesMockRecorder

+ func (mr *MockOnIndexSeriesMockRecorder) NeedsIndexUpdate(indexBlockStartForWrite interface{}) *gomock.Call

+ func (mr *MockOnIndexSeriesMockRecorder) OnIndexPrepare() *gomock.Call

type OnIndexSeries

+ NeedsIndexUpdate func(indexBlockStartForWrite xtime.UnixNano) bool

+ OnIndexPrepare func()

type WriteBatch

+ func (b *WriteBatch) Options() WriteBatchOptions

May 13, 2019

Changes in this version

+ type AggregateFieldFilter [][]byte

+ func (f AggregateFieldFilter) AddIfMissing(field []byte) AggregateFieldFilter

+ func (f AggregateFieldFilter) Allow(term []byte) bool

+ func (f AggregateFieldFilter) SortAndDedupe() AggregateFieldFilter

type AggregateResultsOptions

+ FieldFilter AggregateFieldFilter

type AggregationOptions

+ FieldFilter AggregateFieldFilter

type ReadThroughSegment

+ func (r *ReadThroughSegment) ContainsField(field []byte) (bool, error)

May 6, 2019

Changes in this version

type AggregateResults

+ AddFields func(batch []AggregateResultsEntry) (size int)

+ AggregateResultsOptions func() AggregateResultsOptions

+ type AggregateResultsEntry struct

+ Field ident.ID

+ Terms []ident.ID

+ type AggregateResultsEntryArr []AggregateResultsEntry

+ type AggregateResultsEntryArrPool struct

+ func (p *AggregateResultsEntryArrPool) Get() []AggregateResultsEntry

+ func (p *AggregateResultsEntryArrPool) Init()

+ func (p *AggregateResultsEntryArrPool) Put(arr []AggregateResultsEntry)

+ type AggregateResultsEntryArrayPool interface

+ Get func() []AggregateResultsEntry

+ Init func()

+ Put func(elems []AggregateResultsEntry)

+ func NewAggregateResultsEntryArrayPool(opts AggregateResultsEntryArrayPoolOpts) AggregateResultsEntryArrayPool

+ type AggregateResultsEntryArrayPoolOpts struct

+ Capacity int

+ FinalizeFn AggregateResultsEntryFinalizeFn

+ MaxCapacity int

+ Options pool.ObjectPoolOptions

+ type AggregateResultsEntryFinalizeFn func([]AggregateResultsEntry) []AggregateResultsEntry

type Block

+ Aggregate func(cancellable *resource.CancellableLifetime, opts QueryOptions, ...) (exhaustive bool, err error)

type MockAggregateResults

+ func (m *MockAggregateResults) AddFields(batch []AggregateResultsEntry) int

+ func (m *MockAggregateResults) AggregateResultsOptions() AggregateResultsOptions

type MockAggregateResultsMockRecorder

+ func (mr *MockAggregateResultsMockRecorder) AddFields(batch interface{}) *gomock.Call

+ func (mr *MockAggregateResultsMockRecorder) AggregateResultsOptions() *gomock.Call

type MockBlock

+ func (m *MockBlock) Aggregate(cancellable *resource.CancellableLifetime, opts QueryOptions, ...) (bool, error)

type MockBlockMockRecorder

+ func (mr *MockBlockMockRecorder) Aggregate(cancellable, opts, results interface{}) *gomock.Call

type MockOptions

+ func (m *MockOptions) AggregateResultsEntryArrayPool() AggregateResultsEntryArrayPool

+ func (m *MockOptions) ForwardIndexProbability() float64

+ func (m *MockOptions) ForwardIndexThreshold() float64

+ func (m *MockOptions) SetAggregateResultsEntryArrayPool(value AggregateResultsEntryArrayPool) Options

+ func (m *MockOptions) SetForwardIndexProbability(value float64) Options

+ func (m *MockOptions) SetForwardIndexThreshold(value float64) Options

type MockOptionsMockRecorder

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

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

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

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

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

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

+ type MockfieldsAndTermsIterator struct

+ func NewMockfieldsAndTermsIterator(ctrl *gomock.Controller) *MockfieldsAndTermsIterator

+ func (m *MockfieldsAndTermsIterator) Close() error

+ func (m *MockfieldsAndTermsIterator) Current() ([]byte, []byte)

+ func (m *MockfieldsAndTermsIterator) EXPECT() *MockfieldsAndTermsIteratorMockRecorder

+ func (m *MockfieldsAndTermsIterator) Err() error

+ func (m *MockfieldsAndTermsIterator) Next() bool

+ func (m *MockfieldsAndTermsIterator) Reset(seg segment.Segment, opts fieldsAndTermsIteratorOpts) error

+ type MockfieldsAndTermsIteratorMockRecorder struct

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

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

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

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

+ func (mr *MockfieldsAndTermsIteratorMockRecorder) Reset(seg, opts interface{}) *gomock.Call

type Options

+ AggregateResultsEntryArrayPool func() AggregateResultsEntryArrayPool

+ ForwardIndexProbability func() float64

+ ForwardIndexThreshold func() float64

+ SetAggregateResultsEntryArrayPool func(value AggregateResultsEntryArrayPool) Options

+ SetForwardIndexProbability func(value float64) Options

+ SetForwardIndexThreshold func(value float64) Options

Apr 20, 2019

Changes in this version

+ type MockAggregateResultsPool struct

+ func NewMockAggregateResultsPool(ctrl *gomock.Controller) *MockAggregateResultsPool

+ func (m *MockAggregateResultsPool) EXPECT() *MockAggregateResultsPoolMockRecorder

+ func (m *MockAggregateResultsPool) Get() AggregateResults

+ func (m *MockAggregateResultsPool) Init(alloc AggregateResultsAllocator)

+ func (m *MockAggregateResultsPool) Put(value AggregateResults)

+ type MockAggregateResultsPoolMockRecorder struct

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

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

+ func (mr *MockAggregateResultsPoolMockRecorder) Put(value interface{}) *gomock.Call

+ type MockAggregateValuesPool struct

+ func NewMockAggregateValuesPool(ctrl *gomock.Controller) *MockAggregateValuesPool

+ func (m *MockAggregateValuesPool) EXPECT() *MockAggregateValuesPoolMockRecorder

+ func (m *MockAggregateValuesPool) Get() AggregateValues

+ func (m *MockAggregateValuesPool) Init(alloc AggregateValuesAllocator)

+ func (m *MockAggregateValuesPool) Put(value AggregateValues)

+ type MockAggregateValuesPoolMockRecorder struct

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

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

+ func (mr *MockAggregateValuesPoolMockRecorder) Put(value interface{}) *gomock.Call

+ type MockBaseResults struct

+ func NewMockBaseResults(ctrl *gomock.Controller) *MockBaseResults

+ func (m *MockBaseResults) AddDocuments(batch []doc.Document) (int, error)

+ func (m *MockBaseResults) EXPECT() *MockBaseResultsMockRecorder

+ func (m *MockBaseResults) Finalize()

+ func (m *MockBaseResults) Namespace() ident.ID

+ func (m *MockBaseResults) Size() int

+ type MockBaseResultsMockRecorder struct

+ func (mr *MockBaseResultsMockRecorder) AddDocuments(batch interface{}) *gomock.Call

+ func (mr *MockBaseResultsMockRecorder) Finalize() *gomock.Call

+ func (mr *MockBaseResultsMockRecorder) Namespace() *gomock.Call

+ func (mr *MockBaseResultsMockRecorder) Size() *gomock.Call

+ type MockBlockStatsReporter struct

+ func NewMockBlockStatsReporter(ctrl *gomock.Controller) *MockBlockStatsReporter

+ func (m *MockBlockStatsReporter) EXPECT() *MockBlockStatsReporterMockRecorder

+ func (m *MockBlockStatsReporter) ReportSegmentStats(stats BlockSegmentStats)

+ type MockBlockStatsReporterMockRecorder struct

+ func (mr *MockBlockStatsReporterMockRecorder) ReportSegmentStats(stats interface{}) *gomock.Call

+ type MockOptions struct

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

+ func (m *MockOptions) AggregateResultsPool() AggregateResultsPool

+ func (m *MockOptions) AggregateValuesPool() AggregateValuesPool

+ func (m *MockOptions) BackgroundCompactionPlannerOptions() compaction.PlannerOptions

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

+ func (m *MockOptions) ClockOptions() clock.Options

+ func (m *MockOptions) DocumentArrayPool() doc.DocumentArrayPool

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

+ func (m *MockOptions) FSTSegmentOptions() fst.Options

+ func (m *MockOptions) ForegroundCompactionPlannerOptions() compaction.PlannerOptions

+ func (m *MockOptions) IdentifierPool() ident.Pool

+ func (m *MockOptions) InsertMode() InsertMode

+ func (m *MockOptions) InstrumentOptions() instrument.Options

+ func (m *MockOptions) MemSegmentOptions() mem.Options

+ func (m *MockOptions) PostingsListCache() *PostingsListCache

+ func (m *MockOptions) QueryResultsPool() QueryResultsPool

+ func (m *MockOptions) ReadThroughSegmentOptions() ReadThroughSegmentOptions

+ func (m *MockOptions) SegmentBuilderOptions() builder.Options

+ func (m *MockOptions) SetAggregateResultsPool(values AggregateResultsPool) Options

+ func (m *MockOptions) SetAggregateValuesPool(values AggregateValuesPool) Options

+ func (m *MockOptions) SetBackgroundCompactionPlannerOptions(v compaction.PlannerOptions) Options

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

+ func (m *MockOptions) SetClockOptions(value clock.Options) Options

+ func (m *MockOptions) SetDocumentArrayPool(value doc.DocumentArrayPool) Options

+ func (m *MockOptions) SetFSTSegmentOptions(value fst.Options) Options

+ func (m *MockOptions) SetForegroundCompactionPlannerOptions(v compaction.PlannerOptions) Options

+ func (m *MockOptions) SetIdentifierPool(value ident.Pool) Options

+ func (m *MockOptions) SetInsertMode(value InsertMode) Options

+ func (m *MockOptions) SetInstrumentOptions(value instrument.Options) Options

+ func (m *MockOptions) SetMemSegmentOptions(value mem.Options) Options

+ func (m *MockOptions) SetPostingsListCache(value *PostingsListCache) Options

+ func (m *MockOptions) SetQueryResultsPool(values QueryResultsPool) Options

+ func (m *MockOptions) SetReadThroughSegmentOptions(value ReadThroughSegmentOptions) Options

+ func (m *MockOptions) SetSegmentBuilderOptions(value builder.Options) Options

+ func (m *MockOptions) Validate() error

+ type MockOptionsMockRecorder struct

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ func (mr *MockOptionsMockRecorder) SetAggregateResultsPool(values interface{}) *gomock.Call

+ func (mr *MockOptionsMockRecorder) SetAggregateValuesPool(values interface{}) *gomock.Call

+ func (mr *MockOptionsMockRecorder) SetBackgroundCompactionPlannerOptions(v interface{}) *gomock.Call

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

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

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

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

+ func (mr *MockOptionsMockRecorder) SetForegroundCompactionPlannerOptions(v interface{}) *gomock.Call

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

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

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

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

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

+ func (mr *MockOptionsMockRecorder) SetQueryResultsPool(values interface{}) *gomock.Call

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

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

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

+ type MockQueryResultsPool struct

+ func NewMockQueryResultsPool(ctrl *gomock.Controller) *MockQueryResultsPool

+ func (m *MockQueryResultsPool) EXPECT() *MockQueryResultsPoolMockRecorder

+ func (m *MockQueryResultsPool) Get() QueryResults

+ func (m *MockQueryResultsPool) Init(alloc QueryResultsAllocator)

+ func (m *MockQueryResultsPool) Put(value QueryResults)

+ type MockQueryResultsPoolMockRecorder struct

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

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

+ func (mr *MockQueryResultsPoolMockRecorder) Put(value interface{}) *gomock.Call

Apr 11, 2019

Changes in this version

type PatternType

+ const PatternTypeField

type PostingsListCache

+ func (q *PostingsListCache) GetField(segmentUUID uuid.UUID, field string) (postings.List, bool)

+ func (q *PostingsListCache) PutField(segmentUUID uuid.UUID, field string, pl postings.List)

Apr 2, 2019

Changes in this version

type ReadThroughSegment

+ func (r *ReadThroughSegment) ContainsID(id []byte) (bool, error)

+ func (r *ReadThroughSegment) FieldsIterable() segment.FieldsIterable

+ func (r *ReadThroughSegment) Size() int64

+ func (r *ReadThroughSegment) TermsIterable() segment.TermsIterable

Mar 29, 2019

Changes in this version

+ type AggregateQueryResult struct

+ Exhaustive bool

+ Results AggregateResults

+ type AggregateResults interface

+ Map func() *AggregateResultsMap

+ Reset func(nsID ident.ID, aggregateQueryOpts AggregateResultsOptions)

+ func NewAggregateResults(namespaceID ident.ID, aggregateOpts AggregateResultsOptions, opts Options) AggregateResults

+ type AggregateResultsAllocator func() AggregateResults

+ type AggregateResultsMap struct

+ func (m *AggregateResultsMap) Contains(k ident.ID) bool

+ func (m *AggregateResultsMap) Delete(k ident.ID)

+ func (m *AggregateResultsMap) Get(k ident.ID) (AggregateValues, bool)

+ func (m *AggregateResultsMap) Iter() map[AggregateResultsMapHash]AggregateResultsMapEntry

+ func (m *AggregateResultsMap) Len() int

+ func (m *AggregateResultsMap) Reallocate()

+ func (m *AggregateResultsMap) Reset()

+ func (m *AggregateResultsMap) Set(k ident.ID, v AggregateValues)

+ func (m *AggregateResultsMap) SetUnsafe(k ident.ID, v AggregateValues, opts AggregateResultsMapSetUnsafeOptions)

+ type AggregateResultsMapCopyFn func(ident.ID) ident.ID

+ type AggregateResultsMapEntry struct

+ func (e AggregateResultsMapEntry) Key() ident.ID

+ func (e AggregateResultsMapEntry) Value() AggregateValues

+ type AggregateResultsMapEqualsFn func(ident.ID, ident.ID) bool

+ type AggregateResultsMapFinalizeFn func(ident.ID)

+ type AggregateResultsMapHash uint64

+ type AggregateResultsMapHashFn func(ident.ID) AggregateResultsMapHash

+ type AggregateResultsMapSetUnsafeOptions struct

+ NoCopyKey bool

+ NoFinalizeKey bool

+ type AggregateResultsOptions struct

+ SizeLimit int

+ TermFilter AggregateTermFilter

+ Type AggregationType

+ type AggregateResultsPool interface

+ Get func() AggregateResults

+ Init func(alloc AggregateResultsAllocator)

+ Put func(value AggregateResults)

+ func NewAggregateResultsPool(opts pool.ObjectPoolOptions) AggregateResultsPool

+ type AggregateTermFilter [][]byte

+ func (f AggregateTermFilter) Allow(term []byte) bool

+ type AggregateValues struct

+ func MustNewAggregateValues(opts Options, ids ...ident.ID) AggregateValues

+ func NewAggregateValues(opts Options) AggregateValues

+ func (v *AggregateValues) Map() *AggregateValuesMap

+ func (v *AggregateValues) Size() int

+ type AggregateValuesAllocator func() AggregateValues

+ type AggregateValuesMap struct

+ func NewAggregateValuesMap(idPool ident.Pool) *AggregateValuesMap

+ func (m *AggregateValuesMap) Contains(k ident.ID) bool

+ func (m *AggregateValuesMap) Delete(k ident.ID)

+ func (m *AggregateValuesMap) Get(k ident.ID) (struct{}, bool)

+ func (m *AggregateValuesMap) Iter() map[AggregateValuesMapHash]AggregateValuesMapEntry

+ func (m *AggregateValuesMap) Len() int

+ func (m *AggregateValuesMap) Reallocate()

+ func (m *AggregateValuesMap) Reset()

+ func (m *AggregateValuesMap) Set(k ident.ID, v struct{})

+ func (m *AggregateValuesMap) SetUnsafe(k ident.ID, v struct{}, opts AggregateValuesMapSetUnsafeOptions)

+ type AggregateValuesMapCopyFn func(ident.ID) ident.ID

+ type AggregateValuesMapEntry struct

+ func (e AggregateValuesMapEntry) Key() ident.ID

+ func (e AggregateValuesMapEntry) Value() struct{}

+ type AggregateValuesMapEqualsFn func(ident.ID, ident.ID) bool

+ type AggregateValuesMapFinalizeFn func(ident.ID)

+ type AggregateValuesMapHash uint64

+ type AggregateValuesMapHashFn func(ident.ID) AggregateValuesMapHash

+ type AggregateValuesMapSetUnsafeOptions struct

+ NoCopyKey bool

+ NoFinalizeKey bool

+ type AggregateValuesPool interface

+ Get func() AggregateValues

+ Init func(alloc AggregateValuesAllocator)

+ Put func(value AggregateValues)

+ func NewAggregateValuesPool(opts pool.ObjectPoolOptions) AggregateValuesPool

+ type AggregationOptions struct

+ TermFilter AggregateTermFilter

+ Type AggregationType

+ type AggregationType uint8

+ const AggregateTagNames

+ const AggregateTagNamesAndValues

+ type BaseResults interface

+ AddDocuments func(batch []doc.Document) (size int, err error)

+ Finalize func()

+ Namespace func() ident.ID

+ Size func() int

+ type MockAggregateResults struct

+ func NewMockAggregateResults(ctrl *gomock.Controller) *MockAggregateResults

+ func (m *MockAggregateResults) AddDocuments(arg0 []doc.Document) (int, error)

+ func (m *MockAggregateResults) EXPECT() *MockAggregateResultsMockRecorder

+ func (m *MockAggregateResults) Finalize()

+ func (m *MockAggregateResults) Map() *AggregateResultsMap

+ func (m *MockAggregateResults) Namespace() ident.ID

+ func (m *MockAggregateResults) Reset(arg0 ident.ID, arg1 AggregateResultsOptions)

+ func (m *MockAggregateResults) Size() int

+ type MockAggregateResultsMockRecorder struct

+ func (mr *MockAggregateResultsMockRecorder) AddDocuments(arg0 interface{}) *gomock.Call

+ func (mr *MockAggregateResultsMockRecorder) Finalize() *gomock.Call

+ func (mr *MockAggregateResultsMockRecorder) Map() *gomock.Call

+ func (mr *MockAggregateResultsMockRecorder) Namespace() *gomock.Call

+ func (mr *MockAggregateResultsMockRecorder) Reset(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockAggregateResultsMockRecorder) Size() *gomock.Call

+ type MockQueryResults struct

+ func NewMockQueryResults(ctrl *gomock.Controller) *MockQueryResults

+ func (m *MockQueryResults) AddDocuments(arg0 []doc.Document) (int, error)

+ func (m *MockQueryResults) EXPECT() *MockQueryResultsMockRecorder

+ func (m *MockQueryResults) Finalize()

+ func (m *MockQueryResults) Map() *ResultsMap

+ func (m *MockQueryResults) Namespace() ident.ID

+ func (m *MockQueryResults) NoFinalize()

+ func (m *MockQueryResults) Reset(arg0 ident.ID, arg1 QueryResultsOptions)

+ func (m *MockQueryResults) Size() int

+ type MockQueryResultsMockRecorder struct

+ func (mr *MockQueryResultsMockRecorder) AddDocuments(arg0 interface{}) *gomock.Call

+ func (mr *MockQueryResultsMockRecorder) Finalize() *gomock.Call

+ func (mr *MockQueryResultsMockRecorder) Map() *gomock.Call

+ func (mr *MockQueryResultsMockRecorder) Namespace() *gomock.Call

+ func (mr *MockQueryResultsMockRecorder) NoFinalize() *gomock.Call

+ func (mr *MockQueryResultsMockRecorder) Reset(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockQueryResultsMockRecorder) Size() *gomock.Call

type Options

+ AggregateResultsPool func() AggregateResultsPool

+ AggregateValuesPool func() AggregateValuesPool

+ QueryResultsPool func() QueryResultsPool

+ SetAggregateResultsPool func(values AggregateResultsPool) Options

+ SetAggregateValuesPool func(values AggregateValuesPool) Options

+ SetQueryResultsPool func(values QueryResultsPool) Options

+ type QueryResult struct

+ Exhaustive bool

+ Results QueryResults

type QueryResults

+ func NewQueryResults(namespaceID ident.ID, opts QueryResultsOptions, indexOpts Options) QueryResults

+ Map func() *ResultsMap

+ NoFinalize func()

+ Reset func(nsID ident.ID, opts QueryResultsOptions)

+ type QueryResultsAllocator func() QueryResults

+ type QueryResultsOptions struct

+ SizeLimit int

+ type QueryResultsPool interface

+ Get func() QueryResults

+ Init func(alloc QueryResultsAllocator)

+ Put func(value QueryResults)

+ func NewQueryResultsPool(opts pool.ObjectPoolOptions) QueryResultsPool

Mar 21, 2019

Changes in this version

+ type BlockOptions struct

+ BackgroundCompactorMmapDocsData bool

+ ForegroundCompactorMmapDocsData bool

type MockResults

+ func (m *MockResults) AddDocuments(arg0 []doc.Document) (int, error)

type MockResultsMockRecorder

+ func (mr *MockResultsMockRecorder) AddDocuments(arg0 interface{}) *gomock.Call

type Results

+ AddDocuments func(batch []doc.Document) (size int, err error)

+ type ResultsOptions struct

+ SizeLimit int

Feb 20, 2019

Changes in this version

+ func NewPostingsListCache(size int, opts PostingsListCacheOptions) (*PostingsListCache, Closer, error)

+ func NewReadThroughSegment(seg segment.Segment, cache *PostingsListCache, opts ReadThroughSegmentOptions) segment.Segment

+ type Closer func()

type MockResults

+ func (m *MockResults) NoFinalize()

type MockResultsMockRecorder

+ func (mr *MockResultsMockRecorder) NoFinalize() *gomock.Call

type Options

+ PostingsListCache func() *PostingsListCache

+ ReadThroughSegmentOptions func() ReadThroughSegmentOptions

+ SetPostingsListCache func(value *PostingsListCache) Options

+ SetReadThroughSegmentOptions func(value ReadThroughSegmentOptions) Options

+ type PatternType int

+ const PatternTypeRegexp

+ const PatternTypeTerm

+ type PostingsListCache struct

+ func (q *PostingsListCache) GetRegexp(segmentUUID uuid.UUID, pattern string) (postings.List, bool)

+ func (q *PostingsListCache) GetTerm(segmentUUID uuid.UUID, pattern string) (postings.List, bool)

+ func (q *PostingsListCache) PurgeSegment(segmentUUID uuid.UUID)

+ func (q *PostingsListCache) PutRegexp(segmentUUID uuid.UUID, pattern string, pl postings.List)

+ func (q *PostingsListCache) PutTerm(segmentUUID uuid.UUID, pattern string, pl postings.List)

+ func (q *PostingsListCache) Report()

+ type PostingsListCacheOptions struct

+ InstrumentOptions instrument.Options

+ type ReadThroughSegment struct

+ func (r *ReadThroughSegment) Close() error

+ func (r *ReadThroughSegment) Reader() (index.Reader, error)

+ type ReadThroughSegmentOptions struct

+ CacheRegexp bool

+ CacheTerms bool

type Results

+ NoFinalize func()

Feb 3, 2019

Changes in this version

+ var ErrUnableReportStatsBlockClosed = errors.New("unable to report stats, block is closed")

+ var ErrUnableToQueryBlockClosed = errors.New("unable to query, index block is closed")

type Block

+ Stats func(reporter BlockStatsReporter) error

+ type BlockSegmentStats struct

+ Age time.Duration

+ Mutable bool

+ Size int64

+ Type BlockSegmentType

+ type BlockSegmentType uint

+ const ActiveBackgroundSegment

+ const ActiveForegroundSegment

+ const FlushedSegment

+ type BlockStatsReporter interface

+ ReportSegmentStats func(stats BlockSegmentStats)

+ type BlockStatsReporterFn func(stats BlockSegmentStats)

+ func (f BlockStatsReporterFn) ReportSegmentStats(stats BlockSegmentStats)

type MockBlock

+ func (m *MockBlock) Stats(arg0 BlockStatsReporter) error

type MockBlockMockRecorder

+ func (mr *MockBlockMockRecorder) Stats(arg0 interface{}) *gomock.Call

type MockResults

+ func (m *MockResults) AddDocument(arg0 doc.Document) (bool, int, error)

+ func (m *MockResults) AddIDAndTags(arg0 ident.ID, arg1 ident.Tags) (bool, int, error)

type MockResultsMockRecorder

+ func (mr *MockResultsMockRecorder) AddDocument(arg0 interface{}) *gomock.Call

+ func (mr *MockResultsMockRecorder) AddIDAndTags(arg0, arg1 interface{}) *gomock.Call

type Options

+ BackgroundCompactionPlannerOptions func() compaction.PlannerOptions

+ DocumentArrayPool func() doc.DocumentArrayPool

+ FSTSegmentOptions func() fst.Options

+ ForegroundCompactionPlannerOptions func() compaction.PlannerOptions

+ SegmentBuilderOptions func() builder.Options

+ SetBackgroundCompactionPlannerOptions func(v compaction.PlannerOptions) Options

+ SetDocumentArrayPool func(value doc.DocumentArrayPool) Options

+ SetFSTSegmentOptions func(value fst.Options) Options

+ SetForegroundCompactionPlannerOptions func(v compaction.PlannerOptions) Options

+ SetSegmentBuilderOptions func(value builder.Options) Options

type QueryOptions

+ func (o QueryOptions) LimitExceeded(size int) bool

type Results

+ AddDocument func(document doc.Document) (added bool, size int, err error)

+ AddIDAndTags func(id ident.ID, tags ident.Tags) (added bool, size int, err error)

type WriteBatch

+ func (b *WriteBatch) AppendAll(from *WriteBatch)

type WriteBatchEntryResult

+ Done bool

May 24, 2018

Changes in this version

+ var ReservedFieldNameID = doc.IDReservedFieldName

+ func NewBootstrapResultMutableSegmentAllocator(opts Options) result.MutableSegmentAllocator

+ type Block interface

+ AddResults func(results result.IndexBlock) error

+ Close func() error

+ EndTime func() time.Time

+ EvictMutableSegments func() (EvictMutableSegmentResults, error)

+ IsSealed func() bool

+ NeedsMutableSegmentsEvicted func() bool

+ Query func(query Query, opts QueryOptions, results Results) (exhaustive bool, err error)

+ Seal func() error

+ StartTime func() time.Time

+ Tick func(c context.Cancellable) (BlockTickResult, error)

+ WriteBatch func(inserts *WriteBatch) (WriteBatchResult, error)

+ func NewBlock(startTime time.Time, md namespace.Metadata, opts Options) (Block, error)

+ type BlockTickResult struct

+ NumDocs int64

+ NumSegments int64

+ type EvictMutableSegmentResults struct

+ NumDocs int64

+ NumMutableSegments int64

+ func (e *EvictMutableSegmentResults) Add(o EvictMutableSegmentResults)

+ type ForEachWriteBatchByBlockStartFn func(blockStart time.Time, batch *WriteBatch)

+ type ForEachWriteBatchEntryFn func(idx int, entry WriteBatchEntry, doc doc.Document, result WriteBatchEntryResult)

+ type InsertMode byte

+ const InsertAsync

+ const InsertSync

+ type MockBlock struct

+ func NewMockBlock(ctrl *gomock.Controller) *MockBlock

+ func (m *MockBlock) AddResults(arg0 result.IndexBlock) error

+ func (m *MockBlock) Close() error

+ func (m *MockBlock) EXPECT() *MockBlockMockRecorder

+ func (m *MockBlock) EndTime() time.Time

+ func (m *MockBlock) EvictMutableSegments() (EvictMutableSegmentResults, error)

+ func (m *MockBlock) IsSealed() bool

+ func (m *MockBlock) NeedsMutableSegmentsEvicted() bool

+ func (m *MockBlock) Query(arg0 Query, arg1 QueryOptions, arg2 Results) (bool, error)

+ func (m *MockBlock) Seal() error

+ func (m *MockBlock) StartTime() time.Time

+ func (m *MockBlock) Tick(arg0 context.Cancellable) (BlockTickResult, error)

+ func (m *MockBlock) WriteBatch(arg0 *WriteBatch) (WriteBatchResult, error)

+ type MockBlockMockRecorder struct

+ func (mr *MockBlockMockRecorder) AddResults(arg0 interface{}) *gomock.Call

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

+ func (mr *MockBlockMockRecorder) EndTime() *gomock.Call

+ func (mr *MockBlockMockRecorder) EvictMutableSegments() *gomock.Call

+ func (mr *MockBlockMockRecorder) IsSealed() *gomock.Call

+ func (mr *MockBlockMockRecorder) NeedsMutableSegmentsEvicted() *gomock.Call

+ func (mr *MockBlockMockRecorder) Query(arg0, arg1, arg2 interface{}) *gomock.Call

+ func (mr *MockBlockMockRecorder) Seal() *gomock.Call

+ func (mr *MockBlockMockRecorder) StartTime() *gomock.Call

+ func (mr *MockBlockMockRecorder) Tick(arg0 interface{}) *gomock.Call

+ func (mr *MockBlockMockRecorder) WriteBatch(arg0 interface{}) *gomock.Call

+ type MockOnIndexSeries struct

+ func NewMockOnIndexSeries(ctrl *gomock.Controller) *MockOnIndexSeries

+ func (m *MockOnIndexSeries) EXPECT() *MockOnIndexSeriesMockRecorder

+ func (m *MockOnIndexSeries) OnIndexFinalize(arg0 time0.UnixNano)

+ func (m *MockOnIndexSeries) OnIndexSuccess(arg0 time0.UnixNano)

+ type MockOnIndexSeriesMockRecorder struct

+ func (mr *MockOnIndexSeriesMockRecorder) OnIndexFinalize(arg0 interface{}) *gomock.Call

+ func (mr *MockOnIndexSeriesMockRecorder) OnIndexSuccess(arg0 interface{}) *gomock.Call

+ type MockResults struct

+ func NewMockResults(ctrl *gomock.Controller) *MockResults

+ func (m *MockResults) Add(arg0 doc.Document) (bool, int, error)

+ func (m *MockResults) EXPECT() *MockResultsMockRecorder

+ func (m *MockResults) Finalize()

+ func (m *MockResults) Map() *ResultsMap

+ func (m *MockResults) Namespace() ident.ID

+ func (m *MockResults) Reset(arg0 ident.ID)

+ func (m *MockResults) Size() int

+ type MockResultsMockRecorder struct

+ func (mr *MockResultsMockRecorder) Add(arg0 interface{}) *gomock.Call

+ func (mr *MockResultsMockRecorder) Finalize() *gomock.Call

+ func (mr *MockResultsMockRecorder) Map() *gomock.Call

+ func (mr *MockResultsMockRecorder) Namespace() *gomock.Call

+ func (mr *MockResultsMockRecorder) Reset(arg0 interface{}) *gomock.Call

+ func (mr *MockResultsMockRecorder) Size() *gomock.Call

+ type OnIndexSeries interface

+ OnIndexFinalize func(blockStart xtime.UnixNano)

+ OnIndexSuccess func(blockStart xtime.UnixNano)

+ type Options interface

+ CheckedBytesPool func() pool.CheckedBytesPool

+ ClockOptions func() clock.Options

+ IdentifierPool func() ident.Pool

+ InsertMode func() InsertMode

+ InstrumentOptions func() instrument.Options

+ MemSegmentOptions func() mem.Options

+ ResultsPool func() ResultsPool

+ SetCheckedBytesPool func(value pool.CheckedBytesPool) Options

+ SetClockOptions func(value clock.Options) Options

+ SetIdentifierPool func(value ident.Pool) Options

+ SetInsertMode func(value InsertMode) Options

+ SetInstrumentOptions func(value instrument.Options) Options

+ SetMemSegmentOptions func(value mem.Options) Options

+ SetResultsPool func(values ResultsPool) Options

+ Validate func() error

+ func NewOptions() Options

+ type Query struct

+ type QueryMatcher interface

+ func NewQueryMatcher(q Query) QueryMatcher

+ type QueryOptions struct

+ EndExclusive time.Time

+ Limit int

+ StartInclusive time.Time

+ type QueryResults struct

+ Exhaustive bool

+ Results Results

+ type Results interface

+ Add func(d doc.Document) (added bool, size int, err error)

+ Finalize func()

+ Map func() *ResultsMap

+ Namespace func() ident.ID

+ Reset func(nsID ident.ID)

+ Size func() int

+ func NewResults(opts Options) Results

+ type ResultsAllocator func() Results

+ type ResultsMap struct

+ func (m *ResultsMap) Contains(k ident.ID) bool

+ func (m *ResultsMap) Delete(k ident.ID)

+ func (m *ResultsMap) Get(k ident.ID) (ident.Tags, bool)

+ func (m *ResultsMap) Iter() map[ResultsMapHash]ResultsMapEntry

+ func (m *ResultsMap) Len() int

+ func (m *ResultsMap) Reallocate()

+ func (m *ResultsMap) Reset()

+ func (m *ResultsMap) Set(k ident.ID, v ident.Tags)

+ func (m *ResultsMap) SetUnsafe(k ident.ID, v ident.Tags, opts ResultsMapSetUnsafeOptions)

+ type ResultsMapCopyFn func(ident.ID) ident.ID

+ type ResultsMapEntry struct

+ func (e ResultsMapEntry) Key() ident.ID

+ func (e ResultsMapEntry) Value() ident.Tags

+ type ResultsMapEqualsFn func(ident.ID, ident.ID) bool

+ type ResultsMapFinalizeFn func(ident.ID)

+ type ResultsMapHash uint64

+ type ResultsMapHashFn func(ident.ID) ResultsMapHash

+ type ResultsMapSetUnsafeOptions struct

+ NoCopyKey bool

+ NoFinalizeKey bool

+ type ResultsPool interface

+ Get func() Results

+ Init func(alloc ResultsAllocator)

+ Put func(value Results)

+ func NewResultsPool(opts pool.ObjectPoolOptions) ResultsPool

+ type WriteBatch struct

+ func NewWriteBatch(opts WriteBatchOptions) *WriteBatch

+ func (b *WriteBatch) Append(entry WriteBatchEntry, doc doc.Document)

+ func (b *WriteBatch) ForEach(fn ForEachWriteBatchEntryFn)

+ func (b *WriteBatch) ForEachUnmarkedBatchByBlockStart(fn ForEachWriteBatchByBlockStartFn)

+ func (b *WriteBatch) Len() int

+ func (b *WriteBatch) Less(i, j int) bool

+ func (b *WriteBatch) MarkUnmarkedEntriesError(err error)

+ func (b *WriteBatch) MarkUnmarkedEntriesSuccess()

+ func (b *WriteBatch) MarkUnmarkedEntryError(err error, idx int)

+ func (b *WriteBatch) NumErrs() int

+ func (b *WriteBatch) PendingDocs() []doc.Document

+ func (b *WriteBatch) PendingEntries() []WriteBatchEntry

+ func (b *WriteBatch) Reset()

+ func (b *WriteBatch) SortByEnqueued()

+ func (b *WriteBatch) SortByUnmarkedAndIndexBlockStart()

+ func (b *WriteBatch) Swap(i, j int)

+ type WriteBatchEntry struct

+ EnqueuedAt time.Time

+ OnIndexSeries OnIndexSeries

+ Timestamp time.Time

+ func (e WriteBatchEntry) Result() WriteBatchEntryResult

+ type WriteBatchEntryResult struct

+ Err error

+ type WriteBatchOptions struct

+ IndexBlockSize time.Duration

+ InitialCapacity int

+ type WriteBatchResult struct

+ NumError int64

+ NumSuccess int64