index

Jan 18, 2022

Changes in this version

type QueryOptions

+ IterateEqualTimestampStrategy *encoding.IterateEqualTimestampStrategy

+ ReadConsistencyLevel *topology.ReadConsistencyLevel

Oct 7, 2021

Changes in this version

type IterationOptions

+ IterateEqualTimestampStrategy encoding.IterateEqualTimestampStrategy

Sep 10, 2021

Changes in this version

+ type AggregateIterator interface

+ Current func() (field, term []byte)

type AggregateQueryResult

+ Waited int

type AggregateResultsOptions

+ AggregateUsageMetrics AggregateUsageMetrics

+ DocsLimit int

+ type AggregateUsageMetrics interface

+ IncDedupedFields func(val int64)

+ IncDedupedTerms func(val int64)

+ IncTotal func(val int64)

+ IncTotalFields func(val int64)

+ IncTotalTerms func(val int64)

+ func NewAggregateUsageMetrics(ns ident.ID, iOpts instrument.Options) AggregateUsageMetrics

type Block

+ AggregateIter func(ctx context.Context, aggOpts AggregateResultsOptions) (AggregateIterator, error)

+ AggregateWithIter func(ctx context.Context, iter AggregateIterator, opts QueryOptions, ...) error

+ BackgroundCompact func()

+ IsOpen func() bool

+ QueryIter func(ctx context.Context, query Query) (QueryIterator, error)

+ QueryWithIter func(ctx context.Context, opts QueryOptions, iter QueryIterator, ...) error

type BlockOptions

+ ActiveBlock bool

+ type CachedPattern struct

+ CacheKey PostingsListCacheKey

+ Postings postings.List

+ SearchQuery *querypb.Query

+ type CachedPatternForEachFn func(CachedPattern)

+ type CachedPatternsQuery struct

+ PatternType *PatternType

+ type CachedPatternsResult struct

+ InRegistry bool

+ MatchedPatterns int

+ TotalPatterns int

+ type CachedSearchPatternsResult struct

+ CacheSearchesDisabled bool

+ CachedPatternsResult CachedPatternsResult

+ type DocumentResults interface

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

+ type MockAggregateIterator struct

+ func NewMockAggregateIterator(ctrl *gomock.Controller) *MockAggregateIterator

+ func (m *MockAggregateIterator) AddDocs(count int)

+ func (m *MockAggregateIterator) AddSeries(count int)

+ func (m *MockAggregateIterator) Close() error

+ func (m *MockAggregateIterator) Counts() (int, int)

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

+ func (m *MockAggregateIterator) Done() bool

+ func (m *MockAggregateIterator) EXPECT() *MockAggregateIteratorMockRecorder

+ func (m *MockAggregateIterator) Err() error

+ func (m *MockAggregateIterator) Next(ctx context.Context) bool

+ type MockAggregateIteratorMockRecorder struct

+ func (mr *MockAggregateIteratorMockRecorder) AddDocs(count interface{}) *gomock.Call

+ func (mr *MockAggregateIteratorMockRecorder) AddSeries(count interface{}) *gomock.Call

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

+ func (mr *MockAggregateIteratorMockRecorder) Counts() *gomock.Call

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

+ func (mr *MockAggregateIteratorMockRecorder) Done() *gomock.Call

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

+ func (mr *MockAggregateIteratorMockRecorder) Next(ctx interface{}) *gomock.Call

+ type MockAggregateUsageMetrics struct

+ func NewMockAggregateUsageMetrics(ctrl *gomock.Controller) *MockAggregateUsageMetrics

+ func (m *MockAggregateUsageMetrics) EXPECT() *MockAggregateUsageMetricsMockRecorder

+ func (m *MockAggregateUsageMetrics) IncDedupedFields(val int64)

+ func (m *MockAggregateUsageMetrics) IncDedupedTerms(val int64)

+ func (m *MockAggregateUsageMetrics) IncTotal(val int64)

+ func (m *MockAggregateUsageMetrics) IncTotalFields(val int64)

+ func (m *MockAggregateUsageMetrics) IncTotalTerms(val int64)

+ type MockAggregateUsageMetricsMockRecorder struct

+ func (mr *MockAggregateUsageMetricsMockRecorder) IncDedupedFields(val interface{}) *gomock.Call

+ func (mr *MockAggregateUsageMetricsMockRecorder) IncDedupedTerms(val interface{}) *gomock.Call

+ func (mr *MockAggregateUsageMetricsMockRecorder) IncTotal(val interface{}) *gomock.Call

+ func (mr *MockAggregateUsageMetricsMockRecorder) IncTotalFields(val interface{}) *gomock.Call

+ func (mr *MockAggregateUsageMetricsMockRecorder) IncTotalTerms(val interface{}) *gomock.Call

type MockBlock

+ func (m *MockBlock) AggregateIter(ctx context.Context, aggOpts AggregateResultsOptions) (AggregateIterator, error)

+ func (m *MockBlock) AggregateWithIter(ctx context.Context, iter AggregateIterator, opts QueryOptions, ...) error

+ func (m *MockBlock) BackgroundCompact()

+ func (m *MockBlock) IsOpen() bool

+ func (m *MockBlock) QueryIter(ctx context.Context, query Query) (QueryIterator, error)

+ func (m *MockBlock) QueryWithIter(ctx context.Context, opts QueryOptions, iter QueryIterator, ...) error

type MockBlockMockRecorder

+ func (mr *MockBlockMockRecorder) AggregateIter(ctx, aggOpts interface{}) *gomock.Call

+ func (mr *MockBlockMockRecorder) AggregateWithIter(ctx, iter, opts, results, deadline, logFields interface{}) *gomock.Call

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

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

+ func (mr *MockBlockMockRecorder) QueryIter(ctx, query interface{}) *gomock.Call

+ func (mr *MockBlockMockRecorder) QueryWithIter(ctx, opts, iter, results, deadline, logFields interface{}) *gomock.Call

+ type MockDocumentResults struct

+ func NewMockDocumentResults(ctrl *gomock.Controller) *MockDocumentResults

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

+ func (m *MockDocumentResults) EXPECT() *MockDocumentResultsMockRecorder

+ func (m *MockDocumentResults) EnforceLimits() bool

+ func (m *MockDocumentResults) Finalize()

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

+ func (m *MockDocumentResults) Size() int

+ func (m *MockDocumentResults) TotalDocsCount() int

+ type MockDocumentResultsMockRecorder struct

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

+ func (mr *MockDocumentResultsMockRecorder) EnforceLimits() *gomock.Call

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

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

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

+ func (mr *MockDocumentResultsMockRecorder) TotalDocsCount() *gomock.Call

type MockOptions

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

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

type MockOptionsMockRecorder

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

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

+ type MockQueryIterator struct

+ func NewMockQueryIterator(ctrl *gomock.Controller) *MockQueryIterator

+ func (m *MockQueryIterator) AddDocs(count int)

+ func (m *MockQueryIterator) AddSeries(count int)

+ func (m *MockQueryIterator) Close() error

+ func (m *MockQueryIterator) Counts() (int, int)

+ func (m *MockQueryIterator) Current() doc.Document

+ func (m *MockQueryIterator) Done() bool

+ func (m *MockQueryIterator) EXPECT() *MockQueryIteratorMockRecorder

+ func (m *MockQueryIterator) Err() error

+ func (m *MockQueryIterator) Next(ctx context.Context) bool

+ type MockQueryIteratorMockRecorder struct

+ func (mr *MockQueryIteratorMockRecorder) AddDocs(count interface{}) *gomock.Call

+ func (mr *MockQueryIteratorMockRecorder) AddSeries(count interface{}) *gomock.Call

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

+ func (mr *MockQueryIteratorMockRecorder) Counts() *gomock.Call

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

+ func (mr *MockQueryIteratorMockRecorder) Done() *gomock.Call

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

+ func (mr *MockQueryIteratorMockRecorder) Next(ctx interface{}) *gomock.Call

+ type MockResultIterator struct

+ func NewMockResultIterator(ctrl *gomock.Controller) *MockResultIterator

+ func (m *MockResultIterator) AddDocs(count int)

+ func (m *MockResultIterator) AddSeries(count int)

+ func (m *MockResultIterator) Close() error

+ func (m *MockResultIterator) Counts() (int, int)

+ func (m *MockResultIterator) Done() bool

+ func (m *MockResultIterator) EXPECT() *MockResultIteratorMockRecorder

+ func (m *MockResultIterator) Err() error

+ func (m *MockResultIterator) Next(ctx context.Context) bool

+ type MockResultIteratorMockRecorder struct

+ func (mr *MockResultIteratorMockRecorder) AddDocs(count interface{}) *gomock.Call

+ func (mr *MockResultIteratorMockRecorder) AddSeries(count interface{}) *gomock.Call

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

+ func (mr *MockResultIteratorMockRecorder) Counts() *gomock.Call

+ func (mr *MockResultIteratorMockRecorder) Done() *gomock.Call

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

+ func (mr *MockResultIteratorMockRecorder) Next(ctx interface{}) *gomock.Call

+ type MutableSegmentsSegmentStats struct

+ NumDocs int64

+ NumSegments int64

+ type MutableSegmentsStats struct

+ Background MutableSegmentsSegmentStats

+ Foreground MutableSegmentsSegmentStats

+ func (s MutableSegmentsStats) Empty() bool

type Options

+ SearchPostingsListCache func() *PostingsListCache

+ SetSearchPostingsListCache func(value *PostingsListCache) Options

type PatternType

+ const PatternTypeSearch

type PostingsListCache

+ func (q *PostingsListCache) CachedPatterns(uuid uuid.UUID, query CachedPatternsQuery, fn CachedPatternForEachFn) CachedPatternsResult

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

+ func (q *PostingsListCache) PutSearch(segmentUUID uuid.UUID, queryStr string, query search.Query, pl postings.List)

+ func (q *PostingsListCache) Start() Closer

+ type PostingsListCacheKey struct

+ Field string

+ Pattern string

+ PatternType PatternType

type PostingsListCacheOptions

+ func (o PostingsListCacheOptions) Validate() error

+ type QueryIterator interface

+ Current func() doc.Document

+ func NewQueryIter(docIter doc.QueryDocIterator) QueryIterator

type QueryOptions

+ InstanceMultiple float32

+ RequireNoWait bool

+ func (o QueryOptions) Exhaustive(seriesCount, docsCount int) bool

type QueryResult

+ Waited int

type ReadThroughSegment

+ func (r *ReadThroughSegment) CachedSearchPatterns(fn CachedPatternForEachFn) CachedSearchPatternsResult

+ func (r *ReadThroughSegment) PutCachedSearchPattern(queryStr string, query search.Query, pl postings.List)

+ type ReadThroughSegmentCaches struct

+ SearchPostingsListCache *PostingsListCache

+ SegmentPostingsListCache *PostingsListCache

type ReadThroughSegmentOptions

+ CacheSearches bool

+ type ResultDurations struct

+ Processing time.Duration

+ Search time.Duration

+ func (r ResultDurations) AddProcessing(duration time.Duration) ResultDurations

+ func (r ResultDurations) AddSearch(duration time.Duration) ResultDurations

+ type ResultIterator interface

+ AddDocs func(count int)

+ AddSeries func(count int)

+ Close func() error

+ Counts func() (series, docs int)

+ Done func() bool

+ Err func() error

+ Next func(ctx context.Context) bool

type WriteBatch

+ func (b *WriteBatch) MarkEntrySuccess(idx int)

+ func (b *WriteBatch) MarkUnmarkedIfAlreadyIndexedSuccessAndFinalize()

+ func (b *WriteBatch) PendingAny() bool

type WriteBatchResult

+ MutableSegmentsStats MutableSegmentsStats

Jan 21, 2021

Changes in this version

+ const MetadataArrayPoolCapacity

type MockOptions

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

+ func (m *MockOptions) SetMetadataArrayPool(value doc.MetadataArrayPool) Options

type MockOptionsMockRecorder

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

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

type Options

+ MetadataArrayPool func() doc.MetadataArrayPool

+ SetMetadataArrayPool func(value doc.MetadataArrayPool) Options

type QueryOptions

+ Source []byte

Nov 12, 2020

Changes in this version

+ var ErrWideQueryResultsExhausted = errors.New("no more values to add to wide query results")

type BaseResults

+ func NewWideQueryResults(namespaceID ident.ID, idPool ident.Pool, shardFilter shardFilterFn, ...) BaseResults

+ EnforceLimits func() bool

type MockAggregateResults

+ func (m *MockAggregateResults) EnforceLimits() bool

type MockAggregateResultsMockRecorder

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

type MockBaseResults

+ func (m *MockBaseResults) EnforceLimits() bool

type MockBaseResultsMockRecorder

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

type MockQueryResults

+ func (m *MockQueryResults) EnforceLimits() bool

type MockQueryResultsMockRecorder

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

type QueryOptions

+ func (o QueryOptions) LimitsExceeded(seriesCount, docsCount int) bool

type QueryResultsOptions

+ IndexBatchCollector chan<- ident.IDBatch

+ type WideQueryOptions struct

+ BatchSize int

+ EndExclusive time.Time

+ IterationOptions IterationOptions

+ ShardsQueried []uint32

+ StartInclusive time.Time

+ func NewWideQueryOptions(queryStart time.Time, batchSize int, blockSize time.Duration, shards []uint32, ...) (WideQueryOptions, error)

+ func (q *WideQueryOptions) ToQueryOptions() QueryOptions

Sep 21, 2020

Changes in this version

type MockOptions

+ func (m *MockOptions) QueryLimits() limits.QueryLimits

+ func (m *MockOptions) SetQueryLimits(value limits.QueryLimits) Options

type MockOptionsMockRecorder

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

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

type Options

+ QueryLimits func() limits.QueryLimits

+ SetQueryLimits func(value limits.QueryLimits) Options

Aug 22, 2020

Changes in this version

type BlockTickResult

+ FreeMmap int64

+ NumSegmentsBootstrapped int64

+ NumSegmentsMutable int64

Jul 24, 2020

Changes in this version

type AggregateResultsOptions

+ RestrictByQuery *Query

+ type BlockIndexingStats struct

+ IndexConcurrency int

type BlockStatsReporter

+ func NewBlockStatsReporter(reportSegmentStats func(stats BlockSegmentStats), ...) BlockStatsReporter

+ ReportIndexingStats func(stats BlockIndexingStats)

type MockBlockStatsReporter

+ func (m *MockBlockStatsReporter) ReportIndexingStats(stats BlockIndexingStats)

type MockBlockStatsReporterMockRecorder

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

+ type NewBlockFn func(blockStart time.Time, md namespace.Metadata, blockOpts BlockOptions, ...) (Block, error)

Jun 23, 2020

Changes in this version

type QueryOptions

+ DocsLimit int

+ SeriesLimit int

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

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

Jun 12, 2020

Changes in this version

type BaseResults

+ TotalDocsCount func() int

type MockAggregateResults

+ func (m *MockAggregateResults) TotalDocsCount() int

type MockAggregateResultsMockRecorder

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

type MockBaseResults

+ func (m *MockBaseResults) TotalDocsCount() int

type MockBaseResultsMockRecorder

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

type MockQueryResults

+ func (m *MockQueryResults) TotalDocsCount() int

type MockQueryResultsMockRecorder

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

type QueryOptions

+ RequireExhaustive bool

Jun 3, 2020

Changes in this version

+ const DocumentArrayPoolCapacity

+ func NewBootstrapResultDocumentsBuilderAllocator(opts Options) result.DocumentsBuilderAllocator

type AggregateValues

+ func (v *AggregateValues) HasValues() bool

type Block

+ EvictColdMutableSegments func() error

+ MemorySegmentsData func(ctx context.Context) ([]fst.SegmentData, error)

+ NeedsColdMutableSegmentsEvicted func() bool

+ RotateColdMutableSegments func()

+ type IterationOptions struct

+ SeriesIteratorConsolidator encoding.SeriesIteratorConsolidator

type MockBlock

+ func (m *MockBlock) EvictColdMutableSegments() error

+ func (m *MockBlock) MemorySegmentsData(ctx context.Context) ([]fst.SegmentData, error)

+ func (m *MockBlock) NeedsColdMutableSegmentsEvicted() bool

+ func (m *MockBlock) RotateColdMutableSegments()

type MockBlockMockRecorder

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

+ func (mr *MockBlockMockRecorder) MemorySegmentsData(ctx interface{}) *gomock.Call

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

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

type MockOptions

+ func (m *MockOptions) MmapReporter() mmap.Reporter

+ func (m *MockOptions) QueryStats() stats.QueryStats

+ func (m *MockOptions) SetMmapReporter(mmapReporter mmap.Reporter) Options

+ func (m *MockOptions) SetQueryStats(value stats.QueryStats) Options

type MockOptionsMockRecorder

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

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

+ func (mr *MockOptionsMockRecorder) SetMmapReporter(mmapReporter interface{}) *gomock.Call

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

type Options

+ MmapReporter func() mmap.Reporter

+ QueryStats func() stats.QueryStats

+ SetMmapReporter func(mmapReporter mmap.Reporter) Options

+ SetQueryStats func(value stats.QueryStats) Options

type QueryOptions

+ IterationOptions IterationOptions

type ReadThroughSegment

+ func (r *ReadThroughSegment) FreeMmap() error

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