storage

Sep 10, 2019

Changes in this version

+ var ErrDatabaseLoadLimitHit = errors.New("error loading series, database load limit hit")

+ type MemoryTracker interface

+ DecPendingLoadedBytes func()

+ IncNumLoadedBytes func(x int64) (okToLoad bool)

+ MarkLoadedAsPending func()

+ NumLoadedBytes func() int64

+ WaitForDec func()

+ func NewMemoryTracker(opts MemoryTrackerOptions) MemoryTracker

+ type MemoryTrackerOptions struct

+ func NewMemoryTrackerOptions(numLoadedBytesLimit int64) MemoryTrackerOptions

+ type MockMemoryTracker struct

+ func NewMockMemoryTracker(ctrl *gomock.Controller) *MockMemoryTracker

+ func (m *MockMemoryTracker) DecPendingLoadedBytes()

+ func (m *MockMemoryTracker) EXPECT() *MockMemoryTrackerMockRecorder

+ func (m *MockMemoryTracker) IncNumLoadedBytes(x int64) bool

+ func (m *MockMemoryTracker) MarkLoadedAsPending()

+ func (m *MockMemoryTracker) NumLoadedBytes() int64

+ func (m *MockMemoryTracker) WaitForDec()

+ type MockMemoryTrackerMockRecorder struct

+ func (mr *MockMemoryTrackerMockRecorder) DecPendingLoadedBytes() *gomock.Call

+ func (mr *MockMemoryTrackerMockRecorder) IncNumLoadedBytes(x interface{}) *gomock.Call

+ func (mr *MockMemoryTrackerMockRecorder) MarkLoadedAsPending() *gomock.Call

+ func (mr *MockMemoryTrackerMockRecorder) NumLoadedBytes() *gomock.Call

+ func (mr *MockMemoryTrackerMockRecorder) WaitForDec() *gomock.Call

type MockOptions

+ func (m *MockOptions) MemoryTracker() MemoryTracker

+ func (m *MockOptions) SetMemoryTracker(memTracker MemoryTracker) Options

type MockOptionsMockRecorder

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

+ func (mr *MockOptionsMockRecorder) SetMemoryTracker(memTracker interface{}) *gomock.Call

type Options

+ MemoryTracker func() MemoryTracker

+ SetMemoryTracker func(memTracker MemoryTracker) Options

Aug 23, 2019

Changes in this version

type MockdatabaseShard

+ func (m *MockdatabaseShard) CleanupCompactedFileSets() error

+ func (m *MockdatabaseShard) Load(series *result.Map) error

type MockdatabaseShardMockRecorder

+ func (mr *MockdatabaseShardMockRecorder) CleanupCompactedFileSets() *gomock.Call

+ func (mr *MockdatabaseShardMockRecorder) Load(series interface{}) *gomock.Call

type MocknamespaceIndex

+ func (m *MocknamespaceIndex) AssignShardSet(shardSet sharding.ShardSet)

type MocknamespaceIndexMockRecorder

+ func (mr *MocknamespaceIndexMockRecorder) AssignShardSet(shardSet interface{}) *gomock.Call

Jun 14, 2019

Changes in this version

+ func NewLeaseVerifier(retriever flushStateRetriever) *leaseVerifier

type Database

+ FlushState func(namespace ident.ID, shardID uint32, blockStart time.Time) (fileOpState, error)

type MockDatabase

+ func (m *MockDatabase) FlushState(namespace ident.ID, shardID uint32, blockStart time.Time) (fileOpState, error)

type MockDatabaseMockRecorder

+ func (mr *MockDatabaseMockRecorder) FlushState(namespace, shardID, blockStart interface{}) *gomock.Call

type MockOptions

+ func (m *MockOptions) BlockLeaseManager() block.LeaseManager

+ func (m *MockOptions) SetBlockLeaseManager(leaseMgr block.LeaseManager) Options

type MockOptionsMockRecorder

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

+ func (mr *MockOptionsMockRecorder) SetBlockLeaseManager(leaseMgr interface{}) *gomock.Call

type Mockdatabase

+ func (m *Mockdatabase) FlushState(namespace ident.ID, shardID uint32, blockStart time.Time) (fileOpState, error)

type MockdatabaseMockRecorder

+ func (mr *MockdatabaseMockRecorder) FlushState(namespace, shardID, blockStart interface{}) *gomock.Call

type MockdatabaseNamespace

+ func (m *MockdatabaseNamespace) FlushState(shardID uint32, blockStart time.Time) (fileOpState, error)

type MockdatabaseNamespaceMockRecorder

+ func (mr *MockdatabaseNamespaceMockRecorder) FlushState(shardID, blockStart interface{}) *gomock.Call

type Options

+ BlockLeaseManager func() block.LeaseManager

+ SetBlockLeaseManager func(leaseMgr block.LeaseManager) Options

Jun 8, 2019

Changes in this version

type MockdatabaseNamespace

+ func (m *MockdatabaseNamespace) ColdFlush(flush persist.FlushPreparer) error

+ func (m *MockdatabaseNamespace) WarmFlush(blockStart time.Time, ShardBootstrapStates ShardBootstrapStates, ...) error

type MockdatabaseNamespaceMockRecorder

+ func (mr *MockdatabaseNamespaceMockRecorder) ColdFlush(flush interface{}) *gomock.Call

+ func (mr *MockdatabaseNamespaceMockRecorder) WarmFlush(blockStart, ShardBootstrapStates, flush interface{}) *gomock.Call

type MockdatabaseShard

+ func (m *MockdatabaseShard) ColdFlush(flush persist.FlushPreparer, resources coldFlushReuseableResources, ...) error

+ func (m *MockdatabaseShard) FetchBlocksForColdFlush(ctx context.Context, seriesID ident.ID, start time.Time, version int, ...) ([]xio.BlockReader, error)

+ func (m *MockdatabaseShard) TagsFromSeriesID(seriesID ident.ID) (ident.Tags, bool, error)

+ func (m *MockdatabaseShard) WarmFlush(blockStart time.Time, flush persist.FlushPreparer, nsCtx namespace.Context) error

type MockdatabaseShardMockRecorder

+ func (mr *MockdatabaseShardMockRecorder) ColdFlush(flush, resources, nsCtx interface{}) *gomock.Call

+ func (mr *MockdatabaseShardMockRecorder) FetchBlocksForColdFlush(ctx, seriesID, start, version, nsCtx interface{}) *gomock.Call

+ func (mr *MockdatabaseShardMockRecorder) TagsFromSeriesID(seriesID interface{}) *gomock.Call

+ func (mr *MockdatabaseShardMockRecorder) WarmFlush(blockStart, flush, nsCtx interface{}) *gomock.Call

May 18, 2019

Changes in this version

type MockNamespace

+ func (m *MockNamespace) Schema() namespace.SchemaDescr

type MockNamespaceMockRecorder

+ func (mr *MockNamespaceMockRecorder) Schema() *gomock.Call

type MockOptions

+ func (m *MockOptions) SchemaRegistry() namespace.SchemaRegistry

+ func (m *MockOptions) SetSchemaRegistry(registry namespace.SchemaRegistry) Options

type MockOptionsMockRecorder

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

+ func (mr *MockOptionsMockRecorder) SetSchemaRegistry(registry interface{}) *gomock.Call

type MockdatabaseNamespace

+ func (m *MockdatabaseNamespace) Schema() namespace.SchemaDescr

type MockdatabaseNamespaceMockRecorder

+ func (mr *MockdatabaseNamespaceMockRecorder) Schema() *gomock.Call

type Namespace

+ Schema func() namespace.SchemaDescr

type Options

+ func DefaultTestOptions() Options

+ SchemaRegistry func() namespace.SchemaRegistry

+ SetSchemaRegistry func(registry namespace.SchemaRegistry) Options

May 6, 2019

Changes in this version

type MockOptions

+ func (m *MockOptions) SetTruncateType(value series.TruncateType) Options

+ func (m *MockOptions) SetWriteTransformOptions(value series.WriteTransformOptions) Options

+ func (m *MockOptions) TruncateType() series.TruncateType

+ func (m *MockOptions) WriteTransformOptions() series.WriteTransformOptions

type MockOptionsMockRecorder

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

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

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

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

type Options

+ SetTruncateType func(value series.TruncateType) Options

+ SetWriteTransformOptions func(value series.WriteTransformOptions) Options

+ TruncateType func() series.TruncateType

+ WriteTransformOptions func() series.WriteTransformOptions

Apr 11, 2019

Changes in this version

type MockNamespace

+ func (m *MockNamespace) SchemaRegistry() namespace.SchemaRegistry

type MockNamespaceMockRecorder

+ func (mr *MockNamespaceMockRecorder) SchemaRegistry() *gomock.Call

type MockOptions

+ func (m *MockOptions) BufferBucketPool() *series.BufferBucketPool

+ func (m *MockOptions) BufferBucketVersionsPool() *series.BufferBucketVersionsPool

+ func (m *MockOptions) SetBufferBucketPool(value *series.BufferBucketPool) Options

+ func (m *MockOptions) SetBufferBucketVersionsPool(value *series.BufferBucketVersionsPool) Options

type MockOptionsMockRecorder

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

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

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

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

type MockdatabaseNamespace

+ func (m *MockdatabaseNamespace) SchemaRegistry() namespace.SchemaRegistry

+ func (m *MockdatabaseNamespace) SetSchemaRegistry(v namespace.SchemaRegistry) error

type MockdatabaseNamespaceMockRecorder

+ func (mr *MockdatabaseNamespaceMockRecorder) SchemaRegistry() *gomock.Call

+ func (mr *MockdatabaseNamespaceMockRecorder) SetSchemaRegistry(v interface{}) *gomock.Call

type Namespace

+ SchemaRegistry func() namespace.SchemaRegistry

type Options

+ BufferBucketPool func() *series.BufferBucketPool

+ BufferBucketVersionsPool func() *series.BufferBucketVersionsPool

+ SetBufferBucketPool func(value *series.BufferBucketPool) Options

+ SetBufferBucketVersionsPool func(value *series.BufferBucketVersionsPool) Options

Mar 29, 2019

Changes in this version

type Database

+ AggregateQuery func(ctx context.Context, namespace ident.ID, query index.Query, ...) (index.AggregateQueryResult, error)

type MockDatabase

+ func (m *MockDatabase) AggregateQuery(ctx context.Context, namespace ident.ID, query index.Query, ...) (index.AggregateQueryResult, error)

type MockDatabaseMockRecorder

+ func (mr *MockDatabaseMockRecorder) AggregateQuery(ctx, namespace, query, opts interface{}) *gomock.Call

type Mockdatabase

+ func (m *Mockdatabase) AggregateQuery(ctx context.Context, namespace ident.ID, query index.Query, ...) (index.AggregateQueryResult, error)

type MockdatabaseMockRecorder

+ func (mr *MockdatabaseMockRecorder) AggregateQuery(ctx, namespace, query, opts interface{}) *gomock.Call

type MockdatabaseNamespace

+ func (m *MockdatabaseNamespace) AggregateQuery(ctx context.Context, query index.Query, opts index.AggregationOptions) (index.AggregateQueryResult, error)

type MockdatabaseNamespaceMockRecorder

+ func (mr *MockdatabaseNamespaceMockRecorder) AggregateQuery(ctx, query, opts interface{}) *gomock.Call

type MocknamespaceIndex

+ func (m *MocknamespaceIndex) AggregateQuery(ctx context.Context, query index.Query, opts index.AggregationOptions) (index.AggregateQueryResult, error)

type MocknamespaceIndexMockRecorder

+ func (mr *MocknamespaceIndexMockRecorder) AggregateQuery(ctx, query, opts interface{}) *gomock.Call

Feb 3, 2019

Changes in this version

type Database

+ IsBootstrappedAndDurable func() bool

type MockDatabase

+ func (m *MockDatabase) IsBootstrappedAndDurable() bool

type MockDatabaseMockRecorder

+ func (mr *MockDatabaseMockRecorder) IsBootstrappedAndDurable() *gomock.Call

type Mockdatabase

+ func (m *Mockdatabase) IsBootstrappedAndDurable() bool

type MockdatabaseBootstrapManager

+ func (m *MockdatabaseBootstrapManager) LastBootstrapCompletionTime() (time.Time, bool)

type MockdatabaseBootstrapManagerMockRecorder

+ func (mr *MockdatabaseBootstrapManagerMockRecorder) LastBootstrapCompletionTime() *gomock.Call

type MockdatabaseFileSystemManager

+ func (m *MockdatabaseFileSystemManager) LastSuccessfulSnapshotStartTime() (time.Time, bool)

type MockdatabaseFileSystemManagerMockRecorder

+ func (mr *MockdatabaseFileSystemManagerMockRecorder) LastSuccessfulSnapshotStartTime() *gomock.Call

type MockdatabaseFlushManager

+ func (m *MockdatabaseFlushManager) LastSuccessfulSnapshotStartTime() (time.Time, bool)

type MockdatabaseFlushManagerMockRecorder

+ func (mr *MockdatabaseFlushManagerMockRecorder) LastSuccessfulSnapshotStartTime() *gomock.Call

type MockdatabaseMediator

+ func (m *MockdatabaseMediator) LastBootstrapCompletionTime() (time.Time, bool)

+ func (m *MockdatabaseMediator) LastSuccessfulSnapshotStartTime() (time.Time, bool)

type MockdatabaseMediatorMockRecorder

+ func (mr *MockdatabaseMediatorMockRecorder) LastBootstrapCompletionTime() *gomock.Call

+ func (mr *MockdatabaseMediatorMockRecorder) LastSuccessfulSnapshotStartTime() *gomock.Call

type MockdatabaseMockRecorder

+ func (mr *MockdatabaseMockRecorder) IsBootstrappedAndDurable() *gomock.Call

type MocknamespaceIndex

+ func (m *MocknamespaceIndex) BootstrapsDone() uint

type MocknamespaceIndexMockRecorder

+ func (mr *MocknamespaceIndexMockRecorder) BootstrapsDone() *gomock.Call

Nov 19, 2018

Changes in this version

type Database

+ BatchWriter func(namespace ident.ID, batchSize int) (ts.BatchWriter, error)

+ WriteBatch func(ctx context.Context, namespace ident.ID, writes ts.BatchWriter, ...) error

+ WriteTaggedBatch func(ctx context.Context, namespace ident.ID, writes ts.BatchWriter, ...) error

+ type IndexedErrorHandler interface

+ HandleError func(index int, err error)

type MockDatabase

+ func (m *MockDatabase) BatchWriter(namespace ident.ID, batchSize int) (ts.BatchWriter, error)

+ func (m *MockDatabase) WriteBatch(ctx context.Context, namespace ident.ID, writes ts.BatchWriter, ...) error

+ func (m *MockDatabase) WriteTaggedBatch(ctx context.Context, namespace ident.ID, writes ts.BatchWriter, ...) error

type MockDatabaseMockRecorder

+ func (mr *MockDatabaseMockRecorder) BatchWriter(namespace, batchSize interface{}) *gomock.Call

+ func (mr *MockDatabaseMockRecorder) WriteBatch(ctx, namespace, writes, errHandler 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 MockOptions

+ func (m *MockOptions) SetWriteBatchPool(value *ts.WriteBatchPool) Options

+ func (m *MockOptions) WriteBatchPool() *ts.WriteBatchPool

type MockOptionsMockRecorder

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

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

type Mockdatabase

+ func (m *Mockdatabase) BatchWriter(namespace ident.ID, batchSize int) (ts.BatchWriter, error)

+ func (m *Mockdatabase) WriteBatch(ctx context.Context, namespace ident.ID, writes ts.BatchWriter, ...) error

+ func (m *Mockdatabase) WriteTaggedBatch(ctx context.Context, namespace ident.ID, writes ts.BatchWriter, ...) error

type MockdatabaseMockRecorder

+ func (mr *MockdatabaseMockRecorder) BatchWriter(namespace, batchSize interface{}) *gomock.Call

+ func (mr *MockdatabaseMockRecorder) WriteBatch(ctx, namespace, writes, errHandler interface{}) *gomock.Call

+ func (mr *MockdatabaseMockRecorder) WriteTaggedBatch(ctx, namespace, writes, errHandler interface{}) *gomock.Call

type Options

+ SetWriteBatchPool func(value *ts.WriteBatchPool) Options

+ WriteBatchPool func() *ts.WriteBatchPool

Aug 10, 2018

Changes in this version

type MockdatabaseNamespace

+ func (m *MockdatabaseNamespace) IsCapturedBySnapshot(alignedInclusiveStart, alignedInclusiveEnd, t time.Time) (bool, error)

type MockdatabaseNamespaceMockRecorder

+ func (mr *MockdatabaseNamespaceMockRecorder) IsCapturedBySnapshot(alignedInclusiveStart, alignedInclusiveEnd, t interface{}) *gomock.Call

Jul 16, 2018

Changes in this version

type MockOptions

+ func (m *MockOptions) QueryIDsWorkerPool() sync0.WorkerPool

+ func (m *MockOptions) SetQueryIDsWorkerPool(value sync0.WorkerPool) Options

type MockOptionsMockRecorder

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

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

type Options

+ QueryIDsWorkerPool func() xsync.WorkerPool

+ SetQueryIDsWorkerPool func(value xsync.WorkerPool) Options

May 24, 2018

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

+ AssignShardSet func(shardSet sharding.ShardSet)

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

+ FetchBlocksMetadata func(ctx context.Context, namespace ident.ID, shard uint32, start, end time.Time, ...) (block.FetchBlocksMetadataResults, *int64, error)

+ FetchBlocksMetadataV2 func(ctx context.Context, namespace ident.ID, shard uint32, start, end time.Time, ...) (block.FetchBlocksMetadataResults, PageToken, error)

+ IsBootstrapped 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.QueryResults, 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

+ WriteTagged func(ctx context.Context, namespace ident.ID, id ident.ID, tags ident.TagIterator, ...) error

+ func NewDatabase(shardSet sharding.ShardSet, opts Options) (Database, error)

+ type DatabaseBootstrapState struct

+ NamespaceBootstrapStates NamespaceBootstrapStates

+ type MockDatabase struct

+ func NewMockDatabase(ctrl *gomock.Controller) *MockDatabase

+ func (m *MockDatabase) AssignShardSet(shardSet sharding.ShardSet)

+ 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) FetchBlocksMetadata(ctx context.Context, namespace ident.ID, shard uint32, start, end time.Time, ...) (block.FetchBlocksMetadataResults, *int64, 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) 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.QueryResults, 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) WriteTagged(ctx context.Context, namespace, id ident.ID, tags ident.TagIterator, ...) error

+ type MockDatabaseMockRecorder struct

+ func (mr *MockDatabaseMockRecorder) AssignShardSet(shardSet 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) FetchBlocksMetadata(ctx, namespace, shard, start, end, limit, pageToken, opts 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) 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) WriteTagged(ctx, namespace, id, tags, timestamp, value, unit, annotation 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) 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) Shards() *gomock.Call

+ type MockOptions struct

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

+ func (m *MockOptions) BootstrapProcessProvider() bootstrap.ProcessProvider

+ 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) ErrorCounterOptions() xcounter.Options

+ 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) MaxFlushRetries() int

+ func (m *MockOptions) MinimumSnapshotInterval() time.Duration

+ func (m *MockOptions) MultiReaderIteratorPool() encoding.MultiReaderIteratorPool

+ func (m *MockOptions) NamespaceInitializer() namespace.Initializer

+ func (m *MockOptions) PersistManager() persist.Manager

+ 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) 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) 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) SetErrorCounterOptions(value xcounter.Options) 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) SetMaxFlushRetries(value int) Options

+ func (m *MockOptions) SetMinimumSnapshotInterval(value time.Duration) 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) 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) SetSegmentReaderPool(value xio.SegmentReaderPool) Options

+ func (m *MockOptions) SetSeriesCachePolicy(value series.CachePolicy) Options

+ func (m *MockOptions) SetSeriesOptions(value series.Options) Options

+ func (m *MockOptions) Validate() error

+ type MockOptionsMockRecorder struct

+ func (mr *MockOptionsMockRecorder) BootstrapProcessProvider() *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) ErrorCounterOptions() *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) MaxFlushRetries() *gomock.Call

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

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

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

+ func (mr *MockOptionsMockRecorder) PersistManager() *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) 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) 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) SetErrorCounterOptions(value interface{}) *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) SetMaxFlushRetries(value interface{}) *gomock.Call

+ func (mr *MockOptionsMockRecorder) SetMinimumSnapshotInterval(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) 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) SetSegmentReaderPool(value interface{}) *gomock.Call

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

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

+ func (mr *MockOptionsMockRecorder) Validate() *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) AssignShardSet(shardSet sharding.ShardSet)

+ 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) FetchBlocksMetadata(ctx context.Context, namespace ident.ID, shard uint32, start, end time.Time, ...) (block.FetchBlocksMetadataResults, *int64, 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) 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.QueryResults, 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) WriteTagged(ctx context.Context, namespace, id ident.ID, tags ident.TagIterator, ...) 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) Report()

+ type MockdatabaseBootstrapManagerMockRecorder struct

+ func (mr *MockdatabaseBootstrapManagerMockRecorder) Bootstrap() *gomock.Call

+ func (mr *MockdatabaseBootstrapManagerMockRecorder) IsBootstrapped() *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) 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) 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) Report()

+ type MockdatabaseFlushManagerMockRecorder struct

+ func (mr *MockdatabaseFlushManagerMockRecorder) Flush(tickStart, dbBootstrapStateAtTickStart interface{}) *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) 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) 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) AssignShardSet(shardSet 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) FetchBlocksMetadata(ctx, namespace, shard, start, end, limit, pageToken, opts 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) 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) WriteTagged(ctx, namespace, id, tags, timestamp, value, unit, annotation interface{}) *gomock.Call

+ type MockdatabaseNamespace struct

+ func NewMockdatabaseNamespace(ctrl *gomock.Controller) *MockdatabaseNamespace

+ 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) FetchBlocksMetadata(ctx context.Context, shardID uint32, start, end time.Time, ...) (block.FetchBlocksMetadataResults, *int64, 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) 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.QueryResults, 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) Shards() []Shard

+ func (m *MockdatabaseNamespace) Snapshot(blockStart, snapshotTime time.Time, flush persist.DataFlush) error

+ func (m *MockdatabaseNamespace) Tick(c context.Cancellable) error

+ func (m *MockdatabaseNamespace) Truncate() (int64, error)

+ func (m *MockdatabaseNamespace) Write(ctx context.Context, id ident.ID, timestamp time.Time, value float64, ...) error

+ func (m *MockdatabaseNamespace) WriteTagged(ctx context.Context, id ident.ID, tags ident.TagIterator, timestamp time.Time, ...) error

+ type MockdatabaseNamespaceMockRecorder struct

+ 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) FetchBlocksMetadata(ctx, shardID, start, end, limit, pageToken, opts 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) 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) Shards() *gomock.Call

+ func (mr *MockdatabaseNamespaceMockRecorder) Snapshot(blockStart, snapshotTime, flush interface{}) *gomock.Call

+ func (mr *MockdatabaseNamespaceMockRecorder) Tick(c 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) CleanupSnapshots(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) ([]block.FetchBlockResult, error)

+ func (m *MockdatabaseShard) FetchBlocksMetadata(ctx context.Context, start, end time.Time, limit, pageToken int64, ...) (block.FetchBlocksMetadataResults, *int64, 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.DataFlush) 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.DataFlush) error

+ func (m *MockdatabaseShard) SnapshotState() (bool, time.Time)

+ func (m *MockdatabaseShard) Tick(c context.Cancellable) (tickResult, error)

+ func (m *MockdatabaseShard) Write(ctx context.Context, id ident.ID, timestamp time.Time, value float64, ...) error

+ func (m *MockdatabaseShard) WriteTagged(ctx context.Context, id ident.ID, tags ident.TagIterator, timestamp time.Time, ...) 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) CleanupSnapshots(earliestToRetain interface{}) *gomock.Call

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

+ func (mr *MockdatabaseShardMockRecorder) FetchBlocks(ctx, id, starts interface{}) *gomock.Call

+ func (mr *MockdatabaseShardMockRecorder) FetchBlocksMetadata(ctx, start, end, limit, pageToken, opts interface{}) *gomock.Call

+ func (mr *MockdatabaseShardMockRecorder) FetchBlocksMetadataV2(ctx, start, end, limit, pageToken, opts interface{}) *gomock.Call

+ func (mr *MockdatabaseShardMockRecorder) Flush(blockStart, flush 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 interface{}) *gomock.Call

+ func (mr *MockdatabaseShardMockRecorder) Repair(ctx, tr, repairer interface{}) *gomock.Call

+ func (mr *MockdatabaseShardMockRecorder) Snapshot(blockStart, snapshotStart, flush interface{}) *gomock.Call

+ func (mr *MockdatabaseShardMockRecorder) SnapshotState() *gomock.Call

+ func (mr *MockdatabaseShardMockRecorder) Tick(c interface{}) *gomock.Call

+ func (mr *MockdatabaseShardMockRecorder) Write(ctx, id, timestamp, value, unit, annotation interface{}) *gomock.Call

+ func (mr *MockdatabaseShardMockRecorder) WriteTagged(ctx, id, tags, timestamp, value, unit, annotation 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) error

+ type MockdatabaseTickManagerMockRecorder struct

+ func (mr *MockdatabaseTickManagerMockRecorder) Tick(forceType interface{}) *gomock.Call

+ type MocknamespaceIndex struct

+ func NewMocknamespaceIndex(ctrl *gomock.Controller) *MocknamespaceIndex

+ func (m *MocknamespaceIndex) BlockStartForWriteTime(writeTime time.Time) time0.UnixNano

+ func (m *MocknamespaceIndex) Bootstrap(bootstrapResults result.IndexResults) error

+ 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.QueryResults, error)

+ func (m *MocknamespaceIndex) Tick(c context.Cancellable) (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) BlockStartForWriteTime(writeTime interface{}) *gomock.Call

+ func (mr *MocknamespaceIndexMockRecorder) Bootstrap(bootstrapResults interface{}) *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 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

+ 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

+ 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

+ ErrorCounterOptions func() xcounter.Options

+ 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

+ MaxFlushRetries func() int

+ MinimumSnapshotInterval func() time.Duration

+ MultiReaderIteratorPool func() encoding.MultiReaderIteratorPool

+ NamespaceInitializer func() namespace.Initializer

+ PersistManager func() persist.Manager

+ ReaderIteratorPool func() encoding.ReaderIteratorPool

+ RepairEnabled func() bool

+ RepairOptions func() repair.Options

+ RuntimeOptionsManager func() runtime.OptionsManager

+ SegmentReaderPool func() xio.SegmentReaderPool

+ SeriesCachePolicy func() series.CachePolicy

+ SeriesOptions func() series.Options

+ SetBootstrapProcessProvider func(value bootstrap.ProcessProvider) 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

+ SetErrorCounterOptions func(value xcounter.Options) 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

+ SetMaxFlushRetries func(value int) Options

+ SetMinimumSnapshotInterval func(value time.Duration) Options

+ SetMultiReaderIteratorPool func(value encoding.MultiReaderIteratorPool) Options

+ SetNamespaceInitializer func(value namespace.Initializer) Options

+ SetPersistManager func(value persist.Manager) Options

+ SetReaderIteratorPool func(value encoding.ReaderIteratorPool) Options

+ SetRepairEnabled func(b bool) Options

+ SetRepairOptions func(value repair.Options) Options

+ SetRuntimeOptionsManager func(value runtime.OptionsManager) Options

+ SetSegmentReaderPool func(value xio.SegmentReaderPool) Options

+ SetSeriesCachePolicy func(value series.CachePolicy) Options

+ SetSeriesOptions func(value series.Options) Options

+ Validate func() error

+ 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