Versions in this module Expand all Collapse all v0 v0.9.4 May 21, 2019 Changes in this version + func NewSeriesOptionsFromOptions(opts Options, ropts retention.Options) series.Options + type BootstrapState int + const BootstrapNotStarted + const Bootstrapped + const Bootstrapping + type Database interface + AggregateQuery func(ctx context.Context, namespace ident.ID, query index.Query, ...) (index.AggregateQueryResult, error) + AssignShardSet func(shardSet sharding.ShardSet) + BatchWriter func(namespace ident.ID, batchSize int) (ts.BatchWriter, error) + Bootstrap func() error + BootstrapState func() DatabaseBootstrapState + Close func() error + FetchBlocks func(ctx context.Context, namespace ident.ID, shard uint32, id ident.ID, ...) ([]block.FetchBlockResult, error) + FetchBlocksMetadataV2 func(ctx context.Context, namespace ident.ID, shard uint32, start, end time.Time, ...) (block.FetchBlocksMetadataResults, PageToken, error) + IsBootstrapped func() bool + IsBootstrappedAndDurable func() bool + IsOverloaded func() bool + Namespace func(ns ident.ID) (Namespace, bool) + Namespaces func() []Namespace + Open func() error + Options func() Options + QueryIDs func(ctx context.Context, namespace ident.ID, query index.Query, ...) (index.QueryResult, error) + ReadEncoded func(ctx context.Context, namespace ident.ID, id ident.ID, start, end time.Time) ([][]xio.BlockReader, error) + Repair func() error + ShardSet func() sharding.ShardSet + Terminate func() error + Truncate func(namespace ident.ID) (int64, error) + Write func(ctx context.Context, namespace ident.ID, id ident.ID, timestamp time.Time, ...) error + WriteBatch func(ctx context.Context, namespace ident.ID, writes ts.BatchWriter, ...) error + WriteTagged func(ctx context.Context, namespace ident.ID, id ident.ID, tags ident.TagIterator, ...) error + WriteTaggedBatch func(ctx context.Context, namespace ident.ID, writes ts.BatchWriter, ...) error + func NewDatabase(shardSet sharding.ShardSet, opts Options) (Database, error) + type DatabaseBootstrapState struct + NamespaceBootstrapStates NamespaceBootstrapStates + type IndexedErrorHandler interface + HandleError func(index int, err error) + type MockDatabase struct + func NewMockDatabase(ctrl *gomock.Controller) *MockDatabase + func (m *MockDatabase) AggregateQuery(ctx context.Context, namespace ident.ID, query index.Query, ...) (index.AggregateQueryResult, error) + func (m *MockDatabase) AssignShardSet(shardSet sharding.ShardSet) + func (m *MockDatabase) BatchWriter(namespace ident.ID, batchSize int) (ts.BatchWriter, error) + func (m *MockDatabase) Bootstrap() error + func (m *MockDatabase) BootstrapState() DatabaseBootstrapState + func (m *MockDatabase) Close() error + func (m *MockDatabase) EXPECT() *MockDatabaseMockRecorder + func (m *MockDatabase) FetchBlocks(ctx context.Context, namespace ident.ID, shard uint32, id ident.ID, ...) ([]block.FetchBlockResult, error) + func (m *MockDatabase) FetchBlocksMetadataV2(ctx context.Context, namespace ident.ID, shard uint32, start, end time.Time, ...) (block.FetchBlocksMetadataResults, PageToken, error) + func (m *MockDatabase) IsBootstrapped() bool + func (m *MockDatabase) IsBootstrappedAndDurable() bool + func (m *MockDatabase) IsOverloaded() bool + func (m *MockDatabase) Namespace(ns ident.ID) (Namespace, bool) + func (m *MockDatabase) Namespaces() []Namespace + func (m *MockDatabase) Open() error + func (m *MockDatabase) Options() Options + func (m *MockDatabase) QueryIDs(ctx context.Context, namespace ident.ID, query index.Query, ...) (index.QueryResult, error) + func (m *MockDatabase) ReadEncoded(ctx context.Context, namespace, id ident.ID, start, end time.Time) ([][]xio.BlockReader, error) + func (m *MockDatabase) Repair() error + func (m *MockDatabase) ShardSet() sharding.ShardSet + func (m *MockDatabase) Terminate() error + func (m *MockDatabase) Truncate(namespace ident.ID) (int64, error) + func (m *MockDatabase) Write(ctx context.Context, namespace, id ident.ID, timestamp time.Time, ...) error + func (m *MockDatabase) WriteBatch(ctx context.Context, namespace ident.ID, writes ts.BatchWriter, ...) error + func (m *MockDatabase) WriteTagged(ctx context.Context, namespace, id ident.ID, tags ident.TagIterator, ...) error + func (m *MockDatabase) WriteTaggedBatch(ctx context.Context, namespace ident.ID, writes ts.BatchWriter, ...) error + type MockDatabaseMockRecorder struct + func (mr *MockDatabaseMockRecorder) AggregateQuery(ctx, namespace, query, opts interface{}) *gomock.Call + func (mr *MockDatabaseMockRecorder) AssignShardSet(shardSet interface{}) *gomock.Call + func (mr *MockDatabaseMockRecorder) BatchWriter(namespace, batchSize interface{}) *gomock.Call + func (mr *MockDatabaseMockRecorder) Bootstrap() *gomock.Call + func (mr *MockDatabaseMockRecorder) BootstrapState() *gomock.Call + func (mr *MockDatabaseMockRecorder) Close() *gomock.Call + func (mr *MockDatabaseMockRecorder) FetchBlocks(ctx, namespace, shard, id, starts interface{}) *gomock.Call + func (mr *MockDatabaseMockRecorder) FetchBlocksMetadataV2(ctx, namespace, shard, start, end, limit, pageToken, opts interface{}) *gomock.Call + func (mr *MockDatabaseMockRecorder) IsBootstrapped() *gomock.Call + func (mr *MockDatabaseMockRecorder) IsBootstrappedAndDurable() *gomock.Call + func (mr *MockDatabaseMockRecorder) IsOverloaded() *gomock.Call + func (mr *MockDatabaseMockRecorder) Namespace(ns interface{}) *gomock.Call + func (mr *MockDatabaseMockRecorder) Namespaces() *gomock.Call + func (mr *MockDatabaseMockRecorder) Open() *gomock.Call + func (mr *MockDatabaseMockRecorder) Options() *gomock.Call + func (mr *MockDatabaseMockRecorder) QueryIDs(ctx, namespace, query, opts interface{}) *gomock.Call + func (mr *MockDatabaseMockRecorder) ReadEncoded(ctx, namespace, id, start, end interface{}) *gomock.Call + func (mr *MockDatabaseMockRecorder) Repair() *gomock.Call + func (mr *MockDatabaseMockRecorder) ShardSet() *gomock.Call + func (mr *MockDatabaseMockRecorder) Terminate() *gomock.Call + func (mr *MockDatabaseMockRecorder) Truncate(namespace interface{}) *gomock.Call + func (mr *MockDatabaseMockRecorder) Write(ctx, namespace, id, timestamp, value, unit, annotation interface{}) *gomock.Call + func (mr *MockDatabaseMockRecorder) WriteBatch(ctx, namespace, writes, errHandler interface{}) *gomock.Call + func (mr *MockDatabaseMockRecorder) WriteTagged(ctx, namespace, id, tags, timestamp, value, unit, annotation interface{}) *gomock.Call + func (mr *MockDatabaseMockRecorder) WriteTaggedBatch(ctx, namespace, writes, errHandler interface{}) *gomock.Call + type MockIndexedErrorHandler struct + func NewMockIndexedErrorHandler(ctrl *gomock.Controller) *MockIndexedErrorHandler + func (m *MockIndexedErrorHandler) EXPECT() *MockIndexedErrorHandlerMockRecorder + func (m *MockIndexedErrorHandler) HandleError(index int, err error) + type MockIndexedErrorHandlerMockRecorder struct + func (mr *MockIndexedErrorHandlerMockRecorder) HandleError(index, err interface{}) *gomock.Call + type MockNamespace struct + func NewMockNamespace(ctrl *gomock.Controller) *MockNamespace + func (m *MockNamespace) EXPECT() *MockNamespaceMockRecorder + func (m *MockNamespace) ID() ident.ID + func (m *MockNamespace) NumSeries() int64 + func (m *MockNamespace) Options() namespace.Options + func (m *MockNamespace) Schema() namespace.SchemaDescr + func (m *MockNamespace) Shards() []Shard + type MockNamespaceMockRecorder struct + func (mr *MockNamespaceMockRecorder) ID() *gomock.Call + func (mr *MockNamespaceMockRecorder) NumSeries() *gomock.Call + func (mr *MockNamespaceMockRecorder) Options() *gomock.Call + func (mr *MockNamespaceMockRecorder) Schema() *gomock.Call + func (mr *MockNamespaceMockRecorder) Shards() *gomock.Call + type MockOptions struct + func NewMockOptions(ctrl *gomock.Controller) *MockOptions + func (m *MockOptions) BootstrapProcessProvider() bootstrap.ProcessProvider + func (m *MockOptions) BufferBucketPool() *series.BufferBucketPool + func (m *MockOptions) BufferBucketVersionsPool() *series.BufferBucketVersionsPool + func (m *MockOptions) BytesPool() pool.CheckedBytesPool + func (m *MockOptions) ClockOptions() clock.Options + func (m *MockOptions) CommitLogOptions() commitlog.Options + func (m *MockOptions) ContextPool() context.Pool + func (m *MockOptions) DatabaseBlockOptions() block.Options + func (m *MockOptions) DatabaseBlockRetrieverManager() block.DatabaseBlockRetrieverManager + func (m *MockOptions) DatabaseSeriesPool() series.DatabaseSeriesPool + func (m *MockOptions) EXPECT() *MockOptionsMockRecorder + func (m *MockOptions) EncoderPool() encoding.EncoderPool + func (m *MockOptions) ErrorThresholdForLoad() int64 + func (m *MockOptions) ErrorWindowForLoad() time.Duration + func (m *MockOptions) FetchBlockMetadataResultsPool() block.FetchBlockMetadataResultsPool + func (m *MockOptions) FetchBlocksMetadataResultsPool() block.FetchBlocksMetadataResultsPool + func (m *MockOptions) IdentifierPool() ident.Pool + func (m *MockOptions) IndexOptions() index.Options + func (m *MockOptions) InstrumentOptions() instrument.Options + func (m *MockOptions) MultiReaderIteratorPool() encoding.MultiReaderIteratorPool + func (m *MockOptions) NamespaceInitializer() namespace.Initializer + func (m *MockOptions) PersistManager() persist.Manager + func (m *MockOptions) QueryIDsWorkerPool() sync0.WorkerPool + func (m *MockOptions) ReaderIteratorPool() encoding.ReaderIteratorPool + func (m *MockOptions) RepairEnabled() bool + func (m *MockOptions) RepairOptions() repair.Options + func (m *MockOptions) RuntimeOptionsManager() runtime.OptionsManager + func (m *MockOptions) SchemaRegistry() namespace.SchemaRegistry + func (m *MockOptions) SegmentReaderPool() xio.SegmentReaderPool + func (m *MockOptions) SeriesCachePolicy() series.CachePolicy + func (m *MockOptions) SeriesOptions() series.Options + func (m *MockOptions) SetBootstrapProcessProvider(value bootstrap.ProcessProvider) Options + func (m *MockOptions) SetBufferBucketPool(value *series.BufferBucketPool) Options + func (m *MockOptions) SetBufferBucketVersionsPool(value *series.BufferBucketVersionsPool) Options + func (m *MockOptions) SetBytesPool(value pool.CheckedBytesPool) Options + func (m *MockOptions) SetClockOptions(value clock.Options) Options + func (m *MockOptions) SetCommitLogOptions(value commitlog.Options) Options + func (m *MockOptions) SetContextPool(value context.Pool) Options + func (m *MockOptions) SetDatabaseBlockOptions(value block.Options) Options + func (m *MockOptions) SetDatabaseBlockRetrieverManager(value block.DatabaseBlockRetrieverManager) Options + func (m *MockOptions) SetDatabaseSeriesPool(value series.DatabaseSeriesPool) Options + func (m *MockOptions) SetEncoderPool(value encoding.EncoderPool) Options + func (m *MockOptions) SetEncodingM3TSZPooled() Options + func (m *MockOptions) SetErrorThresholdForLoad(value int64) Options + func (m *MockOptions) SetErrorWindowForLoad(value time.Duration) Options + func (m *MockOptions) SetFetchBlockMetadataResultsPool(value block.FetchBlockMetadataResultsPool) Options + func (m *MockOptions) SetFetchBlocksMetadataResultsPool(value block.FetchBlocksMetadataResultsPool) Options + func (m *MockOptions) SetIdentifierPool(value ident.Pool) Options + func (m *MockOptions) SetIndexOptions(value index.Options) Options + func (m *MockOptions) SetInstrumentOptions(value instrument.Options) Options + func (m *MockOptions) SetMultiReaderIteratorPool(value encoding.MultiReaderIteratorPool) Options + func (m *MockOptions) SetNamespaceInitializer(value namespace.Initializer) Options + func (m *MockOptions) SetPersistManager(value persist.Manager) Options + func (m *MockOptions) SetQueryIDsWorkerPool(value sync0.WorkerPool) Options + func (m *MockOptions) SetReaderIteratorPool(value encoding.ReaderIteratorPool) Options + func (m *MockOptions) SetRepairEnabled(b bool) Options + func (m *MockOptions) SetRepairOptions(value repair.Options) Options + func (m *MockOptions) SetRuntimeOptionsManager(value runtime.OptionsManager) Options + func (m *MockOptions) SetSchemaRegistry(registry namespace.SchemaRegistry) Options + func (m *MockOptions) SetSegmentReaderPool(value xio.SegmentReaderPool) Options + func (m *MockOptions) SetSeriesCachePolicy(value series.CachePolicy) Options + func (m *MockOptions) SetSeriesOptions(value series.Options) Options + func (m *MockOptions) SetTruncateType(value series.TruncateType) Options + func (m *MockOptions) SetWriteBatchPool(value *ts.WriteBatchPool) Options + func (m *MockOptions) SetWriteTransformOptions(value series.WriteTransformOptions) Options + func (m *MockOptions) TruncateType() series.TruncateType + func (m *MockOptions) Validate() error + func (m *MockOptions) WriteBatchPool() *ts.WriteBatchPool + func (m *MockOptions) WriteTransformOptions() series.WriteTransformOptions + type MockOptionsMockRecorder struct + func (mr *MockOptionsMockRecorder) BootstrapProcessProvider() *gomock.Call + func (mr *MockOptionsMockRecorder) BufferBucketPool() *gomock.Call + func (mr *MockOptionsMockRecorder) BufferBucketVersionsPool() *gomock.Call + func (mr *MockOptionsMockRecorder) BytesPool() *gomock.Call + func (mr *MockOptionsMockRecorder) ClockOptions() *gomock.Call + func (mr *MockOptionsMockRecorder) CommitLogOptions() *gomock.Call + func (mr *MockOptionsMockRecorder) ContextPool() *gomock.Call + func (mr *MockOptionsMockRecorder) DatabaseBlockOptions() *gomock.Call + func (mr *MockOptionsMockRecorder) DatabaseBlockRetrieverManager() *gomock.Call + func (mr *MockOptionsMockRecorder) DatabaseSeriesPool() *gomock.Call + func (mr *MockOptionsMockRecorder) EncoderPool() *gomock.Call + func (mr *MockOptionsMockRecorder) ErrorThresholdForLoad() *gomock.Call + func (mr *MockOptionsMockRecorder) ErrorWindowForLoad() *gomock.Call + func (mr *MockOptionsMockRecorder) FetchBlockMetadataResultsPool() *gomock.Call + func (mr *MockOptionsMockRecorder) FetchBlocksMetadataResultsPool() *gomock.Call + func (mr *MockOptionsMockRecorder) IdentifierPool() *gomock.Call + func (mr *MockOptionsMockRecorder) IndexOptions() *gomock.Call + func (mr *MockOptionsMockRecorder) InstrumentOptions() *gomock.Call + func (mr *MockOptionsMockRecorder) MultiReaderIteratorPool() *gomock.Call + func (mr *MockOptionsMockRecorder) NamespaceInitializer() *gomock.Call + func (mr *MockOptionsMockRecorder) PersistManager() *gomock.Call + func (mr *MockOptionsMockRecorder) QueryIDsWorkerPool() *gomock.Call + func (mr *MockOptionsMockRecorder) ReaderIteratorPool() *gomock.Call + func (mr *MockOptionsMockRecorder) RepairEnabled() *gomock.Call + func (mr *MockOptionsMockRecorder) RepairOptions() *gomock.Call + func (mr *MockOptionsMockRecorder) RuntimeOptionsManager() *gomock.Call + func (mr *MockOptionsMockRecorder) SchemaRegistry() *gomock.Call + func (mr *MockOptionsMockRecorder) SegmentReaderPool() *gomock.Call + func (mr *MockOptionsMockRecorder) SeriesCachePolicy() *gomock.Call + func (mr *MockOptionsMockRecorder) SeriesOptions() *gomock.Call + func (mr *MockOptionsMockRecorder) SetBootstrapProcessProvider(value interface{}) *gomock.Call + func (mr *MockOptionsMockRecorder) SetBufferBucketPool(value interface{}) *gomock.Call + func (mr *MockOptionsMockRecorder) SetBufferBucketVersionsPool(value interface{}) *gomock.Call + func (mr *MockOptionsMockRecorder) SetBytesPool(value interface{}) *gomock.Call + func (mr *MockOptionsMockRecorder) SetClockOptions(value interface{}) *gomock.Call + func (mr *MockOptionsMockRecorder) SetCommitLogOptions(value interface{}) *gomock.Call + func (mr *MockOptionsMockRecorder) SetContextPool(value interface{}) *gomock.Call + func (mr *MockOptionsMockRecorder) SetDatabaseBlockOptions(value interface{}) *gomock.Call + func (mr *MockOptionsMockRecorder) SetDatabaseBlockRetrieverManager(value interface{}) *gomock.Call + func (mr *MockOptionsMockRecorder) SetDatabaseSeriesPool(value interface{}) *gomock.Call + func (mr *MockOptionsMockRecorder) SetEncoderPool(value interface{}) *gomock.Call + func (mr *MockOptionsMockRecorder) SetEncodingM3TSZPooled() *gomock.Call + func (mr *MockOptionsMockRecorder) SetErrorThresholdForLoad(value interface{}) *gomock.Call + func (mr *MockOptionsMockRecorder) SetErrorWindowForLoad(value interface{}) *gomock.Call + func (mr *MockOptionsMockRecorder) SetFetchBlockMetadataResultsPool(value interface{}) *gomock.Call + func (mr *MockOptionsMockRecorder) SetFetchBlocksMetadataResultsPool(value interface{}) *gomock.Call + func (mr *MockOptionsMockRecorder) SetIdentifierPool(value interface{}) *gomock.Call + func (mr *MockOptionsMockRecorder) SetIndexOptions(value interface{}) *gomock.Call + func (mr *MockOptionsMockRecorder) SetInstrumentOptions(value interface{}) *gomock.Call + func (mr *MockOptionsMockRecorder) SetMultiReaderIteratorPool(value interface{}) *gomock.Call + func (mr *MockOptionsMockRecorder) SetNamespaceInitializer(value interface{}) *gomock.Call + func (mr *MockOptionsMockRecorder) SetPersistManager(value interface{}) *gomock.Call + func (mr *MockOptionsMockRecorder) SetQueryIDsWorkerPool(value interface{}) *gomock.Call + func (mr *MockOptionsMockRecorder) SetReaderIteratorPool(value interface{}) *gomock.Call + func (mr *MockOptionsMockRecorder) SetRepairEnabled(b interface{}) *gomock.Call + func (mr *MockOptionsMockRecorder) SetRepairOptions(value interface{}) *gomock.Call + func (mr *MockOptionsMockRecorder) SetRuntimeOptionsManager(value interface{}) *gomock.Call + func (mr *MockOptionsMockRecorder) SetSchemaRegistry(registry interface{}) *gomock.Call + func (mr *MockOptionsMockRecorder) SetSegmentReaderPool(value interface{}) *gomock.Call + func (mr *MockOptionsMockRecorder) SetSeriesCachePolicy(value interface{}) *gomock.Call + func (mr *MockOptionsMockRecorder) SetSeriesOptions(value interface{}) *gomock.Call + func (mr *MockOptionsMockRecorder) SetTruncateType(value interface{}) *gomock.Call + func (mr *MockOptionsMockRecorder) SetWriteBatchPool(value interface{}) *gomock.Call + func (mr *MockOptionsMockRecorder) SetWriteTransformOptions(value interface{}) *gomock.Call + func (mr *MockOptionsMockRecorder) TruncateType() *gomock.Call + func (mr *MockOptionsMockRecorder) Validate() *gomock.Call + func (mr *MockOptionsMockRecorder) WriteBatchPool() *gomock.Call + func (mr *MockOptionsMockRecorder) WriteTransformOptions() *gomock.Call + type MockShard struct + func NewMockShard(ctrl *gomock.Controller) *MockShard + func (m *MockShard) BootstrapState() BootstrapState + func (m *MockShard) EXPECT() *MockShardMockRecorder + func (m *MockShard) ID() uint32 + func (m *MockShard) IsBootstrapped() bool + func (m *MockShard) NumSeries() int64 + type MockShardMockRecorder struct + func (mr *MockShardMockRecorder) BootstrapState() *gomock.Call + func (mr *MockShardMockRecorder) ID() *gomock.Call + func (mr *MockShardMockRecorder) IsBootstrapped() *gomock.Call + func (mr *MockShardMockRecorder) NumSeries() *gomock.Call + type Mockdatabase struct + func NewMockdatabase(ctrl *gomock.Controller) *Mockdatabase + func (m *Mockdatabase) AggregateQuery(ctx context.Context, namespace ident.ID, query index.Query, ...) (index.AggregateQueryResult, error) + func (m *Mockdatabase) AssignShardSet(shardSet sharding.ShardSet) + func (m *Mockdatabase) BatchWriter(namespace ident.ID, batchSize int) (ts.BatchWriter, error) + func (m *Mockdatabase) Bootstrap() error + func (m *Mockdatabase) BootstrapState() DatabaseBootstrapState + func (m *Mockdatabase) Close() error + func (m *Mockdatabase) EXPECT() *MockdatabaseMockRecorder + func (m *Mockdatabase) FetchBlocks(ctx context.Context, namespace ident.ID, shard uint32, id ident.ID, ...) ([]block.FetchBlockResult, error) + func (m *Mockdatabase) FetchBlocksMetadataV2(ctx context.Context, namespace ident.ID, shard uint32, start, end time.Time, ...) (block.FetchBlocksMetadataResults, PageToken, error) + func (m *Mockdatabase) GetOwnedNamespaces() ([]databaseNamespace, error) + func (m *Mockdatabase) IsBootstrapped() bool + func (m *Mockdatabase) IsBootstrappedAndDurable() bool + func (m *Mockdatabase) IsOverloaded() bool + func (m *Mockdatabase) Namespace(ns ident.ID) (Namespace, bool) + func (m *Mockdatabase) Namespaces() []Namespace + func (m *Mockdatabase) Open() error + func (m *Mockdatabase) Options() Options + func (m *Mockdatabase) QueryIDs(ctx context.Context, namespace ident.ID, query index.Query, ...) (index.QueryResult, error) + func (m *Mockdatabase) ReadEncoded(ctx context.Context, namespace, id ident.ID, start, end time.Time) ([][]xio.BlockReader, error) + func (m *Mockdatabase) Repair() error + func (m *Mockdatabase) ShardSet() sharding.ShardSet + func (m *Mockdatabase) Terminate() error + func (m *Mockdatabase) Truncate(namespace ident.ID) (int64, error) + func (m *Mockdatabase) UpdateOwnedNamespaces(namespaces namespace.Map) error + func (m *Mockdatabase) Write(ctx context.Context, namespace, id ident.ID, timestamp time.Time, ...) error + func (m *Mockdatabase) WriteBatch(ctx context.Context, namespace ident.ID, writes ts.BatchWriter, ...) error + func (m *Mockdatabase) WriteTagged(ctx context.Context, namespace, id ident.ID, tags ident.TagIterator, ...) error + func (m *Mockdatabase) WriteTaggedBatch(ctx context.Context, namespace ident.ID, writes ts.BatchWriter, ...) error + type MockdatabaseBootstrapManager struct + func NewMockdatabaseBootstrapManager(ctrl *gomock.Controller) *MockdatabaseBootstrapManager + func (m *MockdatabaseBootstrapManager) Bootstrap() error + func (m *MockdatabaseBootstrapManager) EXPECT() *MockdatabaseBootstrapManagerMockRecorder + func (m *MockdatabaseBootstrapManager) IsBootstrapped() bool + func (m *MockdatabaseBootstrapManager) LastBootstrapCompletionTime() (time.Time, bool) + func (m *MockdatabaseBootstrapManager) Report() + type MockdatabaseBootstrapManagerMockRecorder struct + func (mr *MockdatabaseBootstrapManagerMockRecorder) Bootstrap() *gomock.Call + func (mr *MockdatabaseBootstrapManagerMockRecorder) IsBootstrapped() *gomock.Call + func (mr *MockdatabaseBootstrapManagerMockRecorder) LastBootstrapCompletionTime() *gomock.Call + func (mr *MockdatabaseBootstrapManagerMockRecorder) Report() *gomock.Call + type MockdatabaseCleanupManager struct + func NewMockdatabaseCleanupManager(ctrl *gomock.Controller) *MockdatabaseCleanupManager + func (m *MockdatabaseCleanupManager) Cleanup(t time.Time) error + func (m *MockdatabaseCleanupManager) EXPECT() *MockdatabaseCleanupManagerMockRecorder + func (m *MockdatabaseCleanupManager) Report() + type MockdatabaseCleanupManagerMockRecorder struct + func (mr *MockdatabaseCleanupManagerMockRecorder) Cleanup(t interface{}) *gomock.Call + func (mr *MockdatabaseCleanupManagerMockRecorder) Report() *gomock.Call + type MockdatabaseFileSystemManager struct + func NewMockdatabaseFileSystemManager(ctrl *gomock.Controller) *MockdatabaseFileSystemManager + func (m *MockdatabaseFileSystemManager) Cleanup(t time.Time) error + func (m *MockdatabaseFileSystemManager) Disable() fileOpStatus + func (m *MockdatabaseFileSystemManager) EXPECT() *MockdatabaseFileSystemManagerMockRecorder + func (m *MockdatabaseFileSystemManager) Enable() fileOpStatus + func (m *MockdatabaseFileSystemManager) Flush(t time.Time, dbBootstrapStateAtTickStart DatabaseBootstrapState) error + func (m *MockdatabaseFileSystemManager) LastSuccessfulSnapshotStartTime() (time.Time, bool) + func (m *MockdatabaseFileSystemManager) Report() + func (m *MockdatabaseFileSystemManager) Run(t time.Time, dbBootstrapStateAtTickStart DatabaseBootstrapState, ...) bool + func (m *MockdatabaseFileSystemManager) Status() fileOpStatus + type MockdatabaseFileSystemManagerMockRecorder struct + func (mr *MockdatabaseFileSystemManagerMockRecorder) Cleanup(t interface{}) *gomock.Call + func (mr *MockdatabaseFileSystemManagerMockRecorder) Disable() *gomock.Call + func (mr *MockdatabaseFileSystemManagerMockRecorder) Enable() *gomock.Call + func (mr *MockdatabaseFileSystemManagerMockRecorder) Flush(t, dbBootstrapStateAtTickStart interface{}) *gomock.Call + func (mr *MockdatabaseFileSystemManagerMockRecorder) LastSuccessfulSnapshotStartTime() *gomock.Call + func (mr *MockdatabaseFileSystemManagerMockRecorder) Report() *gomock.Call + func (mr *MockdatabaseFileSystemManagerMockRecorder) Run(t, dbBootstrapStateAtTickStart, runType, forceType interface{}) *gomock.Call + func (mr *MockdatabaseFileSystemManagerMockRecorder) Status() *gomock.Call + type MockdatabaseFlushManager struct + func NewMockdatabaseFlushManager(ctrl *gomock.Controller) *MockdatabaseFlushManager + func (m *MockdatabaseFlushManager) EXPECT() *MockdatabaseFlushManagerMockRecorder + func (m *MockdatabaseFlushManager) Flush(tickStart time.Time, dbBootstrapStateAtTickStart DatabaseBootstrapState) error + func (m *MockdatabaseFlushManager) LastSuccessfulSnapshotStartTime() (time.Time, bool) + func (m *MockdatabaseFlushManager) Report() + type MockdatabaseFlushManagerMockRecorder struct + func (mr *MockdatabaseFlushManagerMockRecorder) Flush(tickStart, dbBootstrapStateAtTickStart interface{}) *gomock.Call + func (mr *MockdatabaseFlushManagerMockRecorder) LastSuccessfulSnapshotStartTime() *gomock.Call + func (mr *MockdatabaseFlushManagerMockRecorder) Report() *gomock.Call + type MockdatabaseMediator struct + func NewMockdatabaseMediator(ctrl *gomock.Controller) *MockdatabaseMediator + func (m *MockdatabaseMediator) Bootstrap() error + func (m *MockdatabaseMediator) Close() error + func (m *MockdatabaseMediator) DisableFileOps() + func (m *MockdatabaseMediator) EXPECT() *MockdatabaseMediatorMockRecorder + func (m *MockdatabaseMediator) EnableFileOps() + func (m *MockdatabaseMediator) IsBootstrapped() bool + func (m *MockdatabaseMediator) LastBootstrapCompletionTime() (time.Time, bool) + func (m *MockdatabaseMediator) LastSuccessfulSnapshotStartTime() (time.Time, bool) + func (m *MockdatabaseMediator) Open() error + func (m *MockdatabaseMediator) Repair() error + func (m *MockdatabaseMediator) Report() + func (m *MockdatabaseMediator) Tick(runType runType, forceType forceType) error + type MockdatabaseMediatorMockRecorder struct + func (mr *MockdatabaseMediatorMockRecorder) Bootstrap() *gomock.Call + func (mr *MockdatabaseMediatorMockRecorder) Close() *gomock.Call + func (mr *MockdatabaseMediatorMockRecorder) DisableFileOps() *gomock.Call + func (mr *MockdatabaseMediatorMockRecorder) EnableFileOps() *gomock.Call + func (mr *MockdatabaseMediatorMockRecorder) IsBootstrapped() *gomock.Call + func (mr *MockdatabaseMediatorMockRecorder) LastBootstrapCompletionTime() *gomock.Call + func (mr *MockdatabaseMediatorMockRecorder) LastSuccessfulSnapshotStartTime() *gomock.Call + func (mr *MockdatabaseMediatorMockRecorder) Open() *gomock.Call + func (mr *MockdatabaseMediatorMockRecorder) Repair() *gomock.Call + func (mr *MockdatabaseMediatorMockRecorder) Report() *gomock.Call + func (mr *MockdatabaseMediatorMockRecorder) Tick(runType, forceType interface{}) *gomock.Call + type MockdatabaseMockRecorder struct + func (mr *MockdatabaseMockRecorder) AggregateQuery(ctx, namespace, query, opts interface{}) *gomock.Call + func (mr *MockdatabaseMockRecorder) AssignShardSet(shardSet interface{}) *gomock.Call + func (mr *MockdatabaseMockRecorder) BatchWriter(namespace, batchSize interface{}) *gomock.Call + func (mr *MockdatabaseMockRecorder) Bootstrap() *gomock.Call + func (mr *MockdatabaseMockRecorder) BootstrapState() *gomock.Call + func (mr *MockdatabaseMockRecorder) Close() *gomock.Call + func (mr *MockdatabaseMockRecorder) FetchBlocks(ctx, namespace, shard, id, starts interface{}) *gomock.Call + func (mr *MockdatabaseMockRecorder) FetchBlocksMetadataV2(ctx, namespace, shard, start, end, limit, pageToken, opts interface{}) *gomock.Call + func (mr *MockdatabaseMockRecorder) GetOwnedNamespaces() *gomock.Call + func (mr *MockdatabaseMockRecorder) IsBootstrapped() *gomock.Call + func (mr *MockdatabaseMockRecorder) IsBootstrappedAndDurable() *gomock.Call + func (mr *MockdatabaseMockRecorder) IsOverloaded() *gomock.Call + func (mr *MockdatabaseMockRecorder) Namespace(ns interface{}) *gomock.Call + func (mr *MockdatabaseMockRecorder) Namespaces() *gomock.Call + func (mr *MockdatabaseMockRecorder) Open() *gomock.Call + func (mr *MockdatabaseMockRecorder) Options() *gomock.Call + func (mr *MockdatabaseMockRecorder) QueryIDs(ctx, namespace, query, opts interface{}) *gomock.Call + func (mr *MockdatabaseMockRecorder) ReadEncoded(ctx, namespace, id, start, end interface{}) *gomock.Call + func (mr *MockdatabaseMockRecorder) Repair() *gomock.Call + func (mr *MockdatabaseMockRecorder) ShardSet() *gomock.Call + func (mr *MockdatabaseMockRecorder) Terminate() *gomock.Call + func (mr *MockdatabaseMockRecorder) Truncate(namespace interface{}) *gomock.Call + func (mr *MockdatabaseMockRecorder) UpdateOwnedNamespaces(namespaces interface{}) *gomock.Call + func (mr *MockdatabaseMockRecorder) Write(ctx, namespace, id, timestamp, value, unit, annotation interface{}) *gomock.Call + func (mr *MockdatabaseMockRecorder) WriteBatch(ctx, namespace, writes, errHandler interface{}) *gomock.Call + func (mr *MockdatabaseMockRecorder) WriteTagged(ctx, namespace, id, tags, timestamp, value, unit, annotation interface{}) *gomock.Call + func (mr *MockdatabaseMockRecorder) WriteTaggedBatch(ctx, namespace, writes, errHandler interface{}) *gomock.Call + type MockdatabaseNamespace struct + func NewMockdatabaseNamespace(ctrl *gomock.Controller) *MockdatabaseNamespace + func (m *MockdatabaseNamespace) AggregateQuery(ctx context.Context, query index.Query, opts index.AggregationOptions) (index.AggregateQueryResult, error) + func (m *MockdatabaseNamespace) AssignShardSet(shardSet sharding.ShardSet) + func (m *MockdatabaseNamespace) Bootstrap(start time.Time, process bootstrap.Process) error + func (m *MockdatabaseNamespace) BootstrapState() ShardBootstrapStates + func (m *MockdatabaseNamespace) Close() error + func (m *MockdatabaseNamespace) EXPECT() *MockdatabaseNamespaceMockRecorder + func (m *MockdatabaseNamespace) FetchBlocks(ctx context.Context, shardID uint32, id ident.ID, starts []time.Time) ([]block.FetchBlockResult, error) + func (m *MockdatabaseNamespace) FetchBlocksMetadataV2(ctx context.Context, shardID uint32, start, end time.Time, limit int64, ...) (block.FetchBlocksMetadataResults, PageToken, error) + func (m *MockdatabaseNamespace) Flush(blockStart time.Time, ShardBootstrapStates ShardBootstrapStates, ...) error + func (m *MockdatabaseNamespace) FlushIndex(flush persist.IndexFlush) error + func (m *MockdatabaseNamespace) GetIndex() (namespaceIndex, error) + func (m *MockdatabaseNamespace) GetOwnedShards() []databaseShard + func (m *MockdatabaseNamespace) ID() ident.ID + func (m *MockdatabaseNamespace) IsCapturedBySnapshot(alignedInclusiveStart, alignedInclusiveEnd, t time.Time) (bool, error) + func (m *MockdatabaseNamespace) NeedsFlush(alignedInclusiveStart, alignedInclusiveEnd time.Time) bool + func (m *MockdatabaseNamespace) NumSeries() int64 + func (m *MockdatabaseNamespace) Options() namespace.Options + func (m *MockdatabaseNamespace) QueryIDs(ctx context.Context, query index.Query, opts index.QueryOptions) (index.QueryResult, error) + func (m *MockdatabaseNamespace) ReadEncoded(ctx context.Context, id ident.ID, start, end time.Time) ([][]xio.BlockReader, error) + func (m *MockdatabaseNamespace) Repair(repairer databaseShardRepairer, tr time0.Range) error + func (m *MockdatabaseNamespace) Schema() namespace.SchemaDescr + func (m *MockdatabaseNamespace) Shards() []Shard + func (m *MockdatabaseNamespace) Snapshot(blockStart, snapshotTime time.Time, flush persist.SnapshotPreparer) error + func (m *MockdatabaseNamespace) Tick(c context.Cancellable, tickStart time.Time) error + func (m *MockdatabaseNamespace) Truncate() (int64, error) + func (m *MockdatabaseNamespace) Write(ctx context.Context, id ident.ID, timestamp time.Time, value float64, ...) (ts.Series, bool, error) + func (m *MockdatabaseNamespace) WriteTagged(ctx context.Context, id ident.ID, tags ident.TagIterator, timestamp time.Time, ...) (ts.Series, bool, error) + type MockdatabaseNamespaceMockRecorder struct + func (mr *MockdatabaseNamespaceMockRecorder) AggregateQuery(ctx, query, opts interface{}) *gomock.Call + func (mr *MockdatabaseNamespaceMockRecorder) AssignShardSet(shardSet interface{}) *gomock.Call + func (mr *MockdatabaseNamespaceMockRecorder) Bootstrap(start, process interface{}) *gomock.Call + func (mr *MockdatabaseNamespaceMockRecorder) BootstrapState() *gomock.Call + func (mr *MockdatabaseNamespaceMockRecorder) Close() *gomock.Call + func (mr *MockdatabaseNamespaceMockRecorder) FetchBlocks(ctx, shardID, id, starts interface{}) *gomock.Call + func (mr *MockdatabaseNamespaceMockRecorder) FetchBlocksMetadataV2(ctx, shardID, start, end, limit, pageToken, opts interface{}) *gomock.Call + func (mr *MockdatabaseNamespaceMockRecorder) Flush(blockStart, ShardBootstrapStates, flush interface{}) *gomock.Call + func (mr *MockdatabaseNamespaceMockRecorder) FlushIndex(flush interface{}) *gomock.Call + func (mr *MockdatabaseNamespaceMockRecorder) GetIndex() *gomock.Call + func (mr *MockdatabaseNamespaceMockRecorder) GetOwnedShards() *gomock.Call + func (mr *MockdatabaseNamespaceMockRecorder) ID() *gomock.Call + func (mr *MockdatabaseNamespaceMockRecorder) IsCapturedBySnapshot(alignedInclusiveStart, alignedInclusiveEnd, t interface{}) *gomock.Call + func (mr *MockdatabaseNamespaceMockRecorder) NeedsFlush(alignedInclusiveStart, alignedInclusiveEnd interface{}) *gomock.Call + func (mr *MockdatabaseNamespaceMockRecorder) NumSeries() *gomock.Call + func (mr *MockdatabaseNamespaceMockRecorder) Options() *gomock.Call + func (mr *MockdatabaseNamespaceMockRecorder) QueryIDs(ctx, query, opts interface{}) *gomock.Call + func (mr *MockdatabaseNamespaceMockRecorder) ReadEncoded(ctx, id, start, end interface{}) *gomock.Call + func (mr *MockdatabaseNamespaceMockRecorder) Repair(repairer, tr interface{}) *gomock.Call + func (mr *MockdatabaseNamespaceMockRecorder) Schema() *gomock.Call + func (mr *MockdatabaseNamespaceMockRecorder) Shards() *gomock.Call + func (mr *MockdatabaseNamespaceMockRecorder) Snapshot(blockStart, snapshotTime, flush interface{}) *gomock.Call + func (mr *MockdatabaseNamespaceMockRecorder) Tick(c, tickStart interface{}) *gomock.Call + func (mr *MockdatabaseNamespaceMockRecorder) Truncate() *gomock.Call + func (mr *MockdatabaseNamespaceMockRecorder) Write(ctx, id, timestamp, value, unit, annotation interface{}) *gomock.Call + func (mr *MockdatabaseNamespaceMockRecorder) WriteTagged(ctx, id, tags, timestamp, value, unit, annotation interface{}) *gomock.Call + type MockdatabaseNamespaceWatch struct + func NewMockdatabaseNamespaceWatch(ctrl *gomock.Controller) *MockdatabaseNamespaceWatch + func (m *MockdatabaseNamespaceWatch) Close() error + func (m *MockdatabaseNamespaceWatch) EXPECT() *MockdatabaseNamespaceWatchMockRecorder + func (m *MockdatabaseNamespaceWatch) Start() error + func (m *MockdatabaseNamespaceWatch) Stop() error + type MockdatabaseNamespaceWatchMockRecorder struct + func (mr *MockdatabaseNamespaceWatchMockRecorder) Close() *gomock.Call + func (mr *MockdatabaseNamespaceWatchMockRecorder) Start() *gomock.Call + func (mr *MockdatabaseNamespaceWatchMockRecorder) Stop() *gomock.Call + type MockdatabaseRepairer struct + func NewMockdatabaseRepairer(ctrl *gomock.Controller) *MockdatabaseRepairer + func (m *MockdatabaseRepairer) EXPECT() *MockdatabaseRepairerMockRecorder + func (m *MockdatabaseRepairer) Repair() error + func (m *MockdatabaseRepairer) Report() + func (m *MockdatabaseRepairer) Start() + func (m *MockdatabaseRepairer) Stop() + type MockdatabaseRepairerMockRecorder struct + func (mr *MockdatabaseRepairerMockRecorder) Repair() *gomock.Call + func (mr *MockdatabaseRepairerMockRecorder) Report() *gomock.Call + func (mr *MockdatabaseRepairerMockRecorder) Start() *gomock.Call + func (mr *MockdatabaseRepairerMockRecorder) Stop() *gomock.Call + type MockdatabaseShard struct + func NewMockdatabaseShard(ctrl *gomock.Controller) *MockdatabaseShard + func (m *MockdatabaseShard) Bootstrap(bootstrappedSeries *result.Map) error + func (m *MockdatabaseShard) BootstrapState() BootstrapState + func (m *MockdatabaseShard) CleanupExpiredFileSets(earliestToRetain time.Time) error + func (m *MockdatabaseShard) Close() error + func (m *MockdatabaseShard) EXPECT() *MockdatabaseShardMockRecorder + func (m *MockdatabaseShard) FetchBlocks(ctx context.Context, id ident.ID, starts []time.Time, nsCtx namespace.Context) ([]block.FetchBlockResult, error) + func (m *MockdatabaseShard) FetchBlocksMetadataV2(ctx context.Context, start, end time.Time, limit int64, pageToken PageToken, ...) (block.FetchBlocksMetadataResults, PageToken, error) + func (m *MockdatabaseShard) Flush(blockStart time.Time, flush persist.FlushPreparer, nsCtx namespace.Context) error + func (m *MockdatabaseShard) FlushState(blockStart time.Time) fileOpState + func (m *MockdatabaseShard) ID() uint32 + func (m *MockdatabaseShard) IsBootstrapped() bool + func (m *MockdatabaseShard) NumSeries() int64 + func (m *MockdatabaseShard) OnEvictedFromWiredList(id ident.ID, blockStart time.Time) + func (m *MockdatabaseShard) ReadEncoded(ctx context.Context, id ident.ID, start, end time.Time, ...) ([][]xio.BlockReader, error) + func (m *MockdatabaseShard) Repair(ctx context.Context, tr time0.Range, repairer databaseShardRepairer) (repair.MetadataComparisonResult, error) + func (m *MockdatabaseShard) Snapshot(blockStart, snapshotStart time.Time, flush persist.SnapshotPreparer, ...) error + func (m *MockdatabaseShard) SnapshotState() (bool, time.Time) + func (m *MockdatabaseShard) Tick(c context.Cancellable, tickStart time.Time, nsCtx namespace.Context) (tickResult, error) + func (m *MockdatabaseShard) Write(ctx context.Context, id ident.ID, timestamp time.Time, value float64, ...) (ts.Series, bool, error) + func (m *MockdatabaseShard) WriteTagged(ctx context.Context, id ident.ID, tags ident.TagIterator, timestamp time.Time, ...) (ts.Series, bool, error) + type MockdatabaseShardMockRecorder struct + func (mr *MockdatabaseShardMockRecorder) Bootstrap(bootstrappedSeries interface{}) *gomock.Call + func (mr *MockdatabaseShardMockRecorder) BootstrapState() *gomock.Call + func (mr *MockdatabaseShardMockRecorder) CleanupExpiredFileSets(earliestToRetain interface{}) *gomock.Call + func (mr *MockdatabaseShardMockRecorder) Close() *gomock.Call + func (mr *MockdatabaseShardMockRecorder) FetchBlocks(ctx, id, starts, nsCtx interface{}) *gomock.Call + func (mr *MockdatabaseShardMockRecorder) FetchBlocksMetadataV2(ctx, start, end, limit, pageToken, opts interface{}) *gomock.Call + func (mr *MockdatabaseShardMockRecorder) Flush(blockStart, flush, nsCtx interface{}) *gomock.Call + func (mr *MockdatabaseShardMockRecorder) FlushState(blockStart interface{}) *gomock.Call + func (mr *MockdatabaseShardMockRecorder) ID() *gomock.Call + func (mr *MockdatabaseShardMockRecorder) IsBootstrapped() *gomock.Call + func (mr *MockdatabaseShardMockRecorder) NumSeries() *gomock.Call + func (mr *MockdatabaseShardMockRecorder) OnEvictedFromWiredList(id, blockStart interface{}) *gomock.Call + func (mr *MockdatabaseShardMockRecorder) ReadEncoded(ctx, id, start, end, nsCtx interface{}) *gomock.Call + func (mr *MockdatabaseShardMockRecorder) Repair(ctx, tr, repairer interface{}) *gomock.Call + func (mr *MockdatabaseShardMockRecorder) Snapshot(blockStart, snapshotStart, flush, nsCtx interface{}) *gomock.Call + func (mr *MockdatabaseShardMockRecorder) SnapshotState() *gomock.Call + func (mr *MockdatabaseShardMockRecorder) Tick(c, tickStart, nsCtx interface{}) *gomock.Call + func (mr *MockdatabaseShardMockRecorder) Write(ctx, id, timestamp, value, unit, annotation, wOpts interface{}) *gomock.Call + func (mr *MockdatabaseShardMockRecorder) WriteTagged(ctx, id, tags, timestamp, value, unit, annotation, wOpts interface{}) *gomock.Call + type MockdatabaseShardRepairer struct + func NewMockdatabaseShardRepairer(ctrl *gomock.Controller) *MockdatabaseShardRepairer + func (m *MockdatabaseShardRepairer) EXPECT() *MockdatabaseShardRepairerMockRecorder + func (m *MockdatabaseShardRepairer) Options() repair.Options + func (m *MockdatabaseShardRepairer) Repair(ctx context.Context, namespace ident.ID, tr time0.Range, shard databaseShard) (repair.MetadataComparisonResult, error) + type MockdatabaseShardRepairerMockRecorder struct + func (mr *MockdatabaseShardRepairerMockRecorder) Options() *gomock.Call + func (mr *MockdatabaseShardRepairerMockRecorder) Repair(ctx, namespace, tr, shard interface{}) *gomock.Call + type MockdatabaseTickManager struct + func NewMockdatabaseTickManager(ctrl *gomock.Controller) *MockdatabaseTickManager + func (m *MockdatabaseTickManager) EXPECT() *MockdatabaseTickManagerMockRecorder + func (m *MockdatabaseTickManager) Tick(forceType forceType, tickStart time.Time) error + type MockdatabaseTickManagerMockRecorder struct + func (mr *MockdatabaseTickManagerMockRecorder) Tick(forceType, tickStart interface{}) *gomock.Call + type MocknamespaceIndex struct + func NewMocknamespaceIndex(ctrl *gomock.Controller) *MocknamespaceIndex + func (m *MocknamespaceIndex) AggregateQuery(ctx context.Context, query index.Query, opts index.AggregationOptions) (index.AggregateQueryResult, error) + func (m *MocknamespaceIndex) BlockStartForWriteTime(writeTime time.Time) time0.UnixNano + func (m *MocknamespaceIndex) Bootstrap(bootstrapResults result.IndexResults) error + func (m *MocknamespaceIndex) BootstrapsDone() uint + func (m *MocknamespaceIndex) CleanupExpiredFileSets(t time.Time) error + func (m *MocknamespaceIndex) Close() error + func (m *MocknamespaceIndex) EXPECT() *MocknamespaceIndexMockRecorder + func (m *MocknamespaceIndex) Flush(flush persist.IndexFlush, shards []databaseShard) error + func (m *MocknamespaceIndex) Query(ctx context.Context, query index.Query, opts index.QueryOptions) (index.QueryResult, error) + func (m *MocknamespaceIndex) Tick(c context.Cancellable, tickStart time.Time) (namespaceIndexTickResult, error) + func (m *MocknamespaceIndex) WriteBatch(batch *index.WriteBatch) error + type MocknamespaceIndexInsertQueue struct + func NewMocknamespaceIndexInsertQueue(ctrl *gomock.Controller) *MocknamespaceIndexInsertQueue + func (m *MocknamespaceIndexInsertQueue) EXPECT() *MocknamespaceIndexInsertQueueMockRecorder + func (m *MocknamespaceIndexInsertQueue) InsertBatch(batch *index.WriteBatch) (*sync.WaitGroup, error) + func (m *MocknamespaceIndexInsertQueue) Start() error + func (m *MocknamespaceIndexInsertQueue) Stop() error + type MocknamespaceIndexInsertQueueMockRecorder struct + func (mr *MocknamespaceIndexInsertQueueMockRecorder) InsertBatch(batch interface{}) *gomock.Call + func (mr *MocknamespaceIndexInsertQueueMockRecorder) Start() *gomock.Call + func (mr *MocknamespaceIndexInsertQueueMockRecorder) Stop() *gomock.Call + type MocknamespaceIndexMockRecorder struct + func (mr *MocknamespaceIndexMockRecorder) AggregateQuery(ctx, query, opts interface{}) *gomock.Call + func (mr *MocknamespaceIndexMockRecorder) BlockStartForWriteTime(writeTime interface{}) *gomock.Call + func (mr *MocknamespaceIndexMockRecorder) Bootstrap(bootstrapResults interface{}) *gomock.Call + func (mr *MocknamespaceIndexMockRecorder) BootstrapsDone() *gomock.Call + func (mr *MocknamespaceIndexMockRecorder) CleanupExpiredFileSets(t interface{}) *gomock.Call + func (mr *MocknamespaceIndexMockRecorder) Close() *gomock.Call + func (mr *MocknamespaceIndexMockRecorder) Flush(flush, shards interface{}) *gomock.Call + func (mr *MocknamespaceIndexMockRecorder) Query(ctx, query, opts interface{}) *gomock.Call + func (mr *MocknamespaceIndexMockRecorder) Tick(c, tickStart interface{}) *gomock.Call + func (mr *MocknamespaceIndexMockRecorder) WriteBatch(batch interface{}) *gomock.Call + type Namespace interface + ID func() ident.ID + NumSeries func() int64 + Options func() namespace.Options + Schema func() namespace.SchemaDescr + Shards func() []Shard + type NamespaceBootstrapStates map[string]ShardBootstrapStates + type NamespacesByID []Namespace + func (n NamespacesByID) Len() int + func (n NamespacesByID) Less(i, j int) bool + func (n NamespacesByID) Swap(i, j int) + type Options interface + BootstrapProcessProvider func() bootstrap.ProcessProvider + BufferBucketPool func() *series.BufferBucketPool + BufferBucketVersionsPool func() *series.BufferBucketVersionsPool + BytesPool func() pool.CheckedBytesPool + ClockOptions func() clock.Options + CommitLogOptions func() commitlog.Options + ContextPool func() context.Pool + DatabaseBlockOptions func() block.Options + DatabaseBlockRetrieverManager func() block.DatabaseBlockRetrieverManager + DatabaseSeriesPool func() series.DatabaseSeriesPool + EncoderPool func() encoding.EncoderPool + ErrorThresholdForLoad func() int64 + ErrorWindowForLoad func() time.Duration + FetchBlockMetadataResultsPool func() block.FetchBlockMetadataResultsPool + FetchBlocksMetadataResultsPool func() block.FetchBlocksMetadataResultsPool + IdentifierPool func() ident.Pool + IndexOptions func() index.Options + InstrumentOptions func() instrument.Options + MultiReaderIteratorPool func() encoding.MultiReaderIteratorPool + NamespaceInitializer func() namespace.Initializer + PersistManager func() persist.Manager + QueryIDsWorkerPool func() xsync.WorkerPool + ReaderIteratorPool func() encoding.ReaderIteratorPool + RepairEnabled func() bool + RepairOptions func() repair.Options + RuntimeOptionsManager func() runtime.OptionsManager + SchemaRegistry func() namespace.SchemaRegistry + SegmentReaderPool func() xio.SegmentReaderPool + SeriesCachePolicy func() series.CachePolicy + SeriesOptions func() series.Options + SetBootstrapProcessProvider func(value bootstrap.ProcessProvider) Options + SetBufferBucketPool func(value *series.BufferBucketPool) Options + SetBufferBucketVersionsPool func(value *series.BufferBucketVersionsPool) Options + SetBytesPool func(value pool.CheckedBytesPool) Options + SetClockOptions func(value clock.Options) Options + SetCommitLogOptions func(value commitlog.Options) Options + SetContextPool func(value context.Pool) Options + SetDatabaseBlockOptions func(value block.Options) Options + SetDatabaseBlockRetrieverManager func(value block.DatabaseBlockRetrieverManager) Options + SetDatabaseSeriesPool func(value series.DatabaseSeriesPool) Options + SetEncoderPool func(value encoding.EncoderPool) Options + SetEncodingM3TSZPooled func() Options + SetErrorThresholdForLoad func(value int64) Options + SetErrorWindowForLoad func(value time.Duration) Options + SetFetchBlockMetadataResultsPool func(value block.FetchBlockMetadataResultsPool) Options + SetFetchBlocksMetadataResultsPool func(value block.FetchBlocksMetadataResultsPool) Options + SetIdentifierPool func(value ident.Pool) Options + SetIndexOptions func(value index.Options) Options + SetInstrumentOptions func(value instrument.Options) Options + SetMultiReaderIteratorPool func(value encoding.MultiReaderIteratorPool) Options + SetNamespaceInitializer func(value namespace.Initializer) Options + SetPersistManager func(value persist.Manager) Options + SetQueryIDsWorkerPool func(value xsync.WorkerPool) Options + SetReaderIteratorPool func(value encoding.ReaderIteratorPool) Options + SetRepairEnabled func(b bool) Options + SetRepairOptions func(value repair.Options) Options + SetRuntimeOptionsManager func(value runtime.OptionsManager) Options + SetSchemaRegistry func(registry namespace.SchemaRegistry) Options + SetSegmentReaderPool func(value xio.SegmentReaderPool) Options + SetSeriesCachePolicy func(value series.CachePolicy) Options + SetSeriesOptions func(value series.Options) Options + SetTruncateType func(value series.TruncateType) Options + SetWriteBatchPool func(value *ts.WriteBatchPool) Options + SetWriteTransformOptions func(value series.WriteTransformOptions) Options + TruncateType func() series.TruncateType + Validate func() error + WriteBatchPool func() *ts.WriteBatchPool + WriteTransformOptions func() series.WriteTransformOptions + func DefaultTestOptions() Options + func NewOptions() Options + type PageToken []byte + type Shard interface + BootstrapState func() BootstrapState + ID func() uint32 + IsBootstrapped func() bool + NumSeries func() int64 + type ShardBootstrapStates map[uint32]BootstrapState
Go to main page