storage

Apr 7, 2022

Changes in this version

type MockShard

+ func (m *MockShard) Close() error

+ func (m *MockShard) Closed() bool

type MockShardMockRecorder

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

+ func (mr *MockShardMockRecorder) Closed() *gomock.Call

type MockdatabaseShard

+ func (m *MockdatabaseShard) Closed() bool

+ func (m *MockdatabaseShard) FilterBlocksNeedSnapshot(blockStarts []time0.UnixNano) []time0.UnixNano

type MockdatabaseShardMockRecorder

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

+ func (mr *MockdatabaseShardMockRecorder) FilterBlocksNeedSnapshot(blockStarts interface{}) *gomock.Call

type Shard

+ Close func() error

+ Closed func() bool

Jan 18, 2022

Changes in this version

+ var AggregateTilesProcesses = []AggregateTilesProcess

type Entry

+ func (entry *Entry) MergeEntryIndexBlockStates(states doc.EntryIndexBlockStates)

+ func (entry *Entry) StringID() string

+ func (entry *Entry) TryReconcileDuplicates()

+ type EntryMetrics struct

+ func NewEntryMetrics(scope tally.Scope) *EntryMetrics

type NewEntryOptions

+ EntryMetrics *EntryMetrics

Nov 19, 2021

Changes in this version

type Entry

+ func (entry *Entry) ReconciledOnIndexSeries() (doc.OnIndexSeries, resource.SimpleCloser, bool)

type MockOptions

+ func (m *MockOptions) CoreFn() sync0.CoreFn

+ func (m *MockOptions) SetCoreFn(value sync0.CoreFn) Options

type MockOptionsMockRecorder

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

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

type Options

+ CoreFn func() xsync.CoreFn

+ SetCoreFn func(value xsync.CoreFn) Options

Oct 7, 2021

Changes in this version

type AggregateTilesOptions

+ BackfillMetricTypes bool

+ MemorizeMetricTypes bool

+ MetricTypeByName map[string]annotation.Payload

+ type BootstrapCompleteFn func(BootstrapResult)

+ type BootstrapEnqueueOptions struct

+ OnCompleteFn BootstrapCompleteFn

type Entry

+ func (entry *Entry) IndexedRange() (xtime.UnixNano, xtime.UnixNano)

Sep 10, 2021

Changes in this version

+ func NewSeriesResolver(wg *sync.WaitGroup, copiedID ident.ID, ...) bootstrap.SeriesRefResolver

type AggregateTilesOptions

+ Process AggregateTilesProcess

+ type AggregateTilesProcess uint8

+ const AggregateTilesAPI

+ const AggregateTilesBackfill

+ const AggregateTilesRegular

+ func (p AggregateTilesProcess) String() string

+ type BootstrapAsyncResult struct

+ func (b *BootstrapAsyncResult) Result() BootstrapResult

+ func (b *BootstrapAsyncResult) WaitForStart()

+ type ColdFlushNsOpts interface

+ ReuseResources func() bool

+ func NewColdFlushNsOpts(reuseResources bool) ColdFlushNsOpts

+ type Entry struct

+ ID ident.ID

+ Index uint64

+ IndexGarbageCollected *xatomic.Bool

+ Series series.DatabaseSeries

+ Shard Shard

+ func NewEntry(opts NewEntryOptions) *Entry

+ func (entry *Entry) DecrementReaderWriterCount()

+ func (entry *Entry) IfAlreadyIndexedMarkIndexSuccessAndFinalize(blockStart xtime.UnixNano) bool

+ func (entry *Entry) IncrementReaderWriterCount()

+ func (entry *Entry) IndexedBlockCount() int

+ func (entry *Entry) IndexedForBlockStart(indexBlockStart xtime.UnixNano) bool

+ func (entry *Entry) LoadBlock(block block.DatabaseBlock, writeType series.WriteType) error

+ func (entry *Entry) NeedsIndexGarbageCollected() bool

+ func (entry *Entry) NeedsIndexUpdate(indexBlockStartForWrite xtime.UnixNano) bool

+ func (entry *Entry) OnIndexFinalize(blockStartNanos xtime.UnixNano)

+ func (entry *Entry) OnIndexPrepare(blockStartNanos xtime.UnixNano)

+ func (entry *Entry) OnIndexSuccess(blockStartNanos xtime.UnixNano)

+ func (entry *Entry) ReaderWriterCount() int32

+ func (entry *Entry) ReleaseRef() error

+ func (entry *Entry) SeriesRef() (bootstrap.SeriesRef, error)

+ func (entry *Entry) SetInsertTime(t time.Time)

+ func (entry *Entry) TryMarkIndexGarbageCollected() bool

+ func (entry *Entry) UniqueIndex() uint64

+ func (entry *Entry) Write(ctx context.Context, timestamp xtime.UnixNano, value float64, unit xtime.Unit, ...) (bool, series.WriteType, error)

+ type FileOpsProcess interface

+ Start func()

+ type FileOpsProcessFn func()

+ func (f FileOpsProcessFn) Start()

+ type IndexWriter interface

+ BlockStartForWriteTime func(writeTime xtime.UnixNano) xtime.UnixNano

+ WritePending func(pending []writes.PendingIndexInsert) error

+ type MockColdFlushNsOpts struct

+ func NewMockColdFlushNsOpts(ctrl *gomock.Controller) *MockColdFlushNsOpts

+ func (m *MockColdFlushNsOpts) EXPECT() *MockColdFlushNsOptsMockRecorder

+ func (m *MockColdFlushNsOpts) ReuseResources() bool

+ type MockColdFlushNsOptsMockRecorder struct

+ func (mr *MockColdFlushNsOptsMockRecorder) ReuseResources() *gomock.Call

+ type MockFileOpsProcess struct

+ func NewMockFileOpsProcess(ctrl *gomock.Controller) *MockFileOpsProcess

+ func (m *MockFileOpsProcess) EXPECT() *MockFileOpsProcessMockRecorder

+ func (m *MockFileOpsProcess) Start()

+ type MockFileOpsProcessMockRecorder struct

+ func (mr *MockFileOpsProcessMockRecorder) Start() *gomock.Call

+ type MockIndexWriter struct

+ func NewMockIndexWriter(ctrl *gomock.Controller) *MockIndexWriter

+ func (m *MockIndexWriter) BlockStartForWriteTime(arg0 time.UnixNano) time.UnixNano

+ func (m *MockIndexWriter) EXPECT() *MockIndexWriterMockRecorder

+ func (m *MockIndexWriter) WritePending(arg0 []writes.PendingIndexInsert) error

+ type MockIndexWriterMockRecorder struct

+ func (mr *MockIndexWriterMockRecorder) BlockStartForWriteTime(arg0 interface{}) *gomock.Call

+ func (mr *MockIndexWriterMockRecorder) WritePending(arg0 interface{}) *gomock.Call

type MockNamespace

+ func (m *MockNamespace) ReadableShardAt(shardID uint32) (databaseShard, namespace.Context, error)

type MockNamespaceIndex

+ func (m *MockNamespaceIndex) BackgroundCompact()

+ func (m *MockNamespaceIndex) CleanupCorruptedFileSets() error

+ func (m *MockNamespaceIndex) WarmFlushBlockStarts() []time0.UnixNano

type MockNamespaceIndexMockRecorder

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

+ func (mr *MockNamespaceIndexMockRecorder) CleanupCorruptedFileSets() *gomock.Call

+ func (mr *MockNamespaceIndexMockRecorder) WarmFlushBlockStarts() *gomock.Call

type MockNamespaceMockRecorder

+ func (mr *MockNamespaceMockRecorder) ReadableShardAt(shardID interface{}) *gomock.Call

type MockOnColdFlushNamespace

+ func (m *MockOnColdFlushNamespace) Abort() error

type MockOnColdFlushNamespaceMockRecorder

+ func (mr *MockOnColdFlushNamespaceMockRecorder) Abort() *gomock.Call

type MockOptions

+ func (m *MockOptions) LimitsOptions() limits.Options

+ func (m *MockOptions) PermitsOptions() permits.Options

+ func (m *MockOptions) SetLimitsOptions(value limits.Options) Options

+ func (m *MockOptions) SetPermitsOptions(value permits.Options) Options

type MockOptionsMockRecorder

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

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

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

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

type MockShard

+ func (m *MockShard) OpenStreamingReader(blockStart time0.UnixNano) (fs.DataFileSetReader, error)

+ func (m *MockShard) TryRetrieveSeriesAndIncrementReaderWriterCount(id ident.ID) (*Entry, WritableSeriesOptions, error)

type MockShardMockRecorder

+ func (mr *MockShardMockRecorder) OpenStreamingReader(blockStart interface{}) *gomock.Call

+ func (mr *MockShardMockRecorder) TryRetrieveSeriesAndIncrementReaderWriterCount(id interface{}) *gomock.Call

type MockdatabaseBootstrapManager

+ func (m *MockdatabaseBootstrapManager) BootstrapEnqueue() *BootstrapAsyncResult

type MockdatabaseBootstrapManagerMockRecorder

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

type MockdatabaseMediator

+ func (m *MockdatabaseMediator) BootstrapEnqueue() *BootstrapAsyncResult

+ func (m *MockdatabaseMediator) EnqueueMutuallyExclusiveFn(fn func()) error

+ func (m *MockdatabaseMediator) IsOpen() bool

type MockdatabaseMediatorMockRecorder

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

+ func (mr *MockdatabaseMediatorMockRecorder) EnqueueMutuallyExclusiveFn(fn interface{}) *gomock.Call

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

type MockdatabaseNamespace

+ func (m *MockdatabaseNamespace) SeriesRefResolver(shardID uint32, id ident.ID, tags ident.TagIterator) (bootstrap.SeriesRefResolver, bool, error)

type MockdatabaseNamespaceMockRecorder

+ func (mr *MockdatabaseNamespaceMockRecorder) SeriesRefResolver(shardID, id, tags interface{}) *gomock.Call

type MockdatabaseShard

+ func (m *MockdatabaseShard) MarkWarmIndexFlushStateSuccessOrError(blockStart time0.UnixNano, err error)

+ func (m *MockdatabaseShard) OpenStreamingReader(blockStart time0.UnixNano) (fs.DataFileSetReader, error)

+ func (m *MockdatabaseShard) SeriesRefResolver(id ident.ID, tags ident.TagIterator) (bootstrap.SeriesRefResolver, error)

+ func (m *MockdatabaseShard) TryRetrieveSeriesAndIncrementReaderWriterCount(id ident.ID) (*Entry, WritableSeriesOptions, error)

type MockdatabaseShardMockRecorder

+ func (mr *MockdatabaseShardMockRecorder) MarkWarmIndexFlushStateSuccessOrError(blockStart, err interface{}) *gomock.Call

+ func (mr *MockdatabaseShardMockRecorder) OpenStreamingReader(blockStart interface{}) *gomock.Call

+ func (mr *MockdatabaseShardMockRecorder) SeriesRefResolver(id, tags interface{}) *gomock.Call

+ func (mr *MockdatabaseShardMockRecorder) TryRetrieveSeriesAndIncrementReaderWriterCount(id interface{}) *gomock.Call

type Namespace

+ ReadableShardAt func(shardID uint32) (databaseShard, namespace.Context, error)

type NamespaceIndex

+ BackgroundCompact func()

+ CleanupCorruptedFileSets func() error

+ WarmFlushBlockStarts func() []xtime.UnixNano

+ type NamespaceRepairOptions struct

+ Force bool

+ type NewEntryOptions struct

+ Index uint64

+ IndexWriter IndexWriter

+ NowFn clock.NowFn

+ Series series.DatabaseSeries

+ Shard Shard

type OnColdFlushNamespace

+ Abort func() error

type Options

+ LimitsOptions func() limits.Options

+ PermitsOptions func() permits.Options

+ SetLimitsOptions func(value limits.Options) Options

+ SetPermitsOptions func(value permits.Options) Options

type Shard

+ OpenStreamingReader func(blockStart xtime.UnixNano) (fs.DataFileSetReader, error)

+ TryRetrieveSeriesAndIncrementReaderWriterCount func(id ident.ID) (*Entry, WritableSeriesOptions, error)

+ type WritableSeriesOptions struct

+ WriteNewSeriesAsync bool

Jan 21, 2021

Changes in this version

type Database

+ BatchProcessWideQuery func(ctx context.Context, n Namespace, query index.Query, ...) error

type MockDatabase

+ func (m *MockDatabase) BatchProcessWideQuery(ctx context.Context, n Namespace, query index.Query, ...) error

type MockDatabaseMockRecorder

+ func (mr *MockDatabaseMockRecorder) BatchProcessWideQuery(ctx, n, query, batchProcessor, opts interface{}) *gomock.Call

type MockNamespace

+ func (m *MockNamespace) DocRef(id ident.ID) (doc.Metadata, bool, error)

+ func (m *MockNamespace) FetchWideEntry(ctx context.Context, id ident.ID, blockStart time.Time, ...) (block.StreamedWideEntry, error)

+ func (m *MockNamespace) WideQueryIDs(ctx context.Context, query index.Query, collector chan *ident.IDBatch, ...) error

type MockNamespaceMockRecorder

+ func (mr *MockNamespaceMockRecorder) DocRef(id interface{}) *gomock.Call

+ func (mr *MockNamespaceMockRecorder) FetchWideEntry(ctx, id, blockStart, filter interface{}) *gomock.Call

+ func (mr *MockNamespaceMockRecorder) WideQueryIDs(ctx, query, collector, opts interface{}) *gomock.Call

type MockOnColdFlushNamespace

+ func (m *MockOnColdFlushNamespace) CheckpointAndMaybeCompact() error

type MockOnColdFlushNamespaceMockRecorder

+ func (mr *MockOnColdFlushNamespaceMockRecorder) CheckpointAndMaybeCompact() *gomock.Call

type MockOptions

+ func (m *MockOptions) ForceColdWritesEnabled() bool

+ func (m *MockOptions) IterationOptions() index.IterationOptions

+ func (m *MockOptions) SetForceColdWritesEnabled(value bool) Options

+ func (m *MockOptions) SetIterationOptions(arg0 index.IterationOptions) Options

+ func (m *MockOptions) SetSourceLoggerBuilder(value limits.SourceLoggerBuilder) Options

+ func (m *MockOptions) SetTileAggregator(aggregator TileAggregator) Options

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

+ func (m *MockOptions) TileAggregator() TileAggregator

type MockOptionsMockRecorder

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

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

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

+ func (mr *MockOptionsMockRecorder) SetIterationOptions(arg0 interface{}) *gomock.Call

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

+ func (mr *MockOptionsMockRecorder) SetTileAggregator(aggregator interface{}) *gomock.Call

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

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

type MockShard

+ func (m *MockShard) ScanData(blockStart time.Time, processor fs.DataEntryProcessor) error

type MockShardMockRecorder

+ func (mr *MockShardMockRecorder) ScanData(blockStart, processor interface{}) *gomock.Call

+ type MockTileAggregator struct

+ func NewMockTileAggregator(ctrl *gomock.Controller) *MockTileAggregator

+ func (m *MockTileAggregator) AggregateTiles(ctx context.Context, sourceNs, targetNs Namespace, shardID uint32, ...) (int64, error)

+ func (m *MockTileAggregator) EXPECT() *MockTileAggregatorMockRecorder

+ type MockTileAggregatorMockRecorder struct

+ func (mr *MockTileAggregatorMockRecorder) AggregateTiles(...) *gomock.Call

type Mockdatabase

+ func (m *Mockdatabase) BatchProcessWideQuery(ctx context.Context, n Namespace, query index.Query, ...) error

type MockdatabaseMockRecorder

+ func (mr *MockdatabaseMockRecorder) BatchProcessWideQuery(ctx, n, query, batchProcessor, opts interface{}) *gomock.Call

type MockdatabaseNamespace

+ func (m *MockdatabaseNamespace) DocRef(id ident.ID) (doc.Metadata, bool, error)

+ func (m *MockdatabaseNamespace) FetchWideEntry(ctx context.Context, id ident.ID, blockStart time.Time, ...) (block.StreamedWideEntry, error)

type MockdatabaseNamespaceMockRecorder

+ func (mr *MockdatabaseNamespaceMockRecorder) DocRef(id interface{}) *gomock.Call

+ func (mr *MockdatabaseNamespaceMockRecorder) FetchWideEntry(ctx, id, blockStart, filter interface{}) *gomock.Call

type MockdatabaseShard

+ func (m *MockdatabaseShard) FetchWideEntry(ctx context.Context, id ident.ID, blockStart time.Time, ...) (block.StreamedWideEntry, error)

+ func (m *MockdatabaseShard) ScanData(blockStart time.Time, processor fs.DataEntryProcessor) error

type MockdatabaseShardMockRecorder

+ func (mr *MockdatabaseShardMockRecorder) FetchWideEntry(ctx, id, blockStart, filter, nsCtx interface{}) *gomock.Call

+ func (mr *MockdatabaseShardMockRecorder) ScanData(blockStart, processor interface{}) *gomock.Call

type Namespace

+ DocRef func(id ident.ID) (doc.Metadata, bool, error)

+ FetchWideEntry func(ctx context.Context, id ident.ID, blockStart time.Time, ...) (block.StreamedWideEntry, error)

+ WideQueryIDs func(ctx context.Context, query index.Query, collector chan *ident.IDBatch, ...) error

+ type NewTileAggregatorFn func(iOpts instrument.Options) TileAggregator

+ type OptionTransform func(Options) Options

type Options

+ ForceColdWritesEnabled func() bool

+ IterationOptions func() index.IterationOptions

+ SetForceColdWritesEnabled func(value bool) Options

+ SetIterationOptions func(index.IterationOptions) Options

+ SetSourceLoggerBuilder func(value limits.SourceLoggerBuilder) Options

+ SetTileAggregator func(aggregator TileAggregator) Options

+ SourceLoggerBuilder func() limits.SourceLoggerBuilder

+ TileAggregator func() TileAggregator

type Shard

+ ScanData func(blockStart time.Time, processor fs.DataEntryProcessor) error

+ type TileAggregator interface

+ AggregateTiles func(ctx context.Context, sourceNs, targetNs Namespace, shardID uint32, ...) (int64, error)

Nov 12, 2020

Changes in this version

type AggregateTilesOptions

+ InsOptions instrument.Options

type Database

+ ReadMismatches func(ctx context.Context, namespace ident.ID, query index.Query, ...) ([]wide.ReadMismatch, error)

+ WideQuery func(ctx context.Context, namespace ident.ID, query index.Query, start time.Time, ...) ([]xio.IndexChecksum, error)

+ type IDBatchProcessor func(batch *ident.IDBatch) error

type MockDatabase

+ func (m *MockDatabase) ReadMismatches(ctx context.Context, namespace ident.ID, query index.Query, ...) ([]wide.ReadMismatch, error)

+ func (m *MockDatabase) WideQuery(ctx context.Context, namespace ident.ID, query index.Query, start time.Time, ...) ([]xio.IndexChecksum, error)

type MockDatabaseMockRecorder

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

+ func (mr *MockDatabaseMockRecorder) WideQuery(ctx, namespace, query, start, shards, iterOpts interface{}) *gomock.Call

type MockNamespace

+ func (m *MockNamespace) ReadOnly() bool

+ func (m *MockNamespace) SetReadOnly(value bool)

type MockNamespaceIndex

+ func (m *MockNamespaceIndex) Bootstrapped() bool

+ func (m *MockNamespaceIndex) WideQuery(ctx context.Context, query index.Query, collector chan *ident.IDBatch, ...) error

type MockNamespaceIndexMockRecorder

+ func (mr *MockNamespaceIndexMockRecorder) Bootstrapped() *gomock.Call

+ func (mr *MockNamespaceIndexMockRecorder) WideQuery(ctx, query, collector, opts interface{}) *gomock.Call

type MockNamespaceMockRecorder

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

+ func (mr *MockNamespaceMockRecorder) SetReadOnly(value interface{}) *gomock.Call

type MockOptions

+ func (m *MockOptions) AdminClient() client.AdminClient

+ func (m *MockOptions) IndexClaimsManager() fs.IndexClaimsManager

+ func (m *MockOptions) SetAdminClient(value client.AdminClient) Options

+ func (m *MockOptions) SetIndexClaimsManager(value fs.IndexClaimsManager) Options

+ func (m *MockOptions) SetWideBatchSize(value int) Options

+ func (m *MockOptions) WideBatchSize() int

type MockOptionsMockRecorder

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

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

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

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

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

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

type Mockdatabase

+ func (m *Mockdatabase) ReadMismatches(ctx context.Context, namespace ident.ID, query index.Query, ...) ([]wide.ReadMismatch, error)

+ func (m *Mockdatabase) WideQuery(ctx context.Context, namespace ident.ID, query index.Query, start time.Time, ...) ([]xio.IndexChecksum, error)

type MockdatabaseMockRecorder

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

+ func (mr *MockdatabaseMockRecorder) WideQuery(ctx, namespace, query, start, shards, iterOpts interface{}) *gomock.Call

type MockdatabaseNamespace

+ func (m *MockdatabaseNamespace) FetchIndexChecksum(ctx context.Context, id ident.ID, blockStart time.Time) (block.StreamedChecksum, error)

+ func (m *MockdatabaseNamespace) FetchReadMismatch(ctx context.Context, mismatchChecker wide.EntryChecksumMismatchChecker, ...) (wide.StreamedMismatch, error)

+ func (m *MockdatabaseNamespace) ReadOnly() bool

+ func (m *MockdatabaseNamespace) SetReadOnly(value bool)

+ func (m *MockdatabaseNamespace) WideQueryIDs(ctx context.Context, query index.Query, collector chan *ident.IDBatch, ...) error

type MockdatabaseNamespaceMockRecorder

+ func (mr *MockdatabaseNamespaceMockRecorder) FetchIndexChecksum(ctx, id, blockStart interface{}) *gomock.Call

+ func (mr *MockdatabaseNamespaceMockRecorder) FetchReadMismatch(ctx, mismatchChecker, id, blockStart interface{}) *gomock.Call

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

+ func (mr *MockdatabaseNamespaceMockRecorder) SetReadOnly(value interface{}) *gomock.Call

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

type MockdatabaseShard

+ func (m *MockdatabaseShard) FetchIndexChecksum(ctx context.Context, id ident.ID, blockStart time.Time, ...) (block.StreamedChecksum, error)

+ func (m *MockdatabaseShard) FetchReadMismatch(ctx context.Context, mismatchChecker wide.EntryChecksumMismatchChecker, ...) (wide.StreamedMismatch, error)

type MockdatabaseShardMockRecorder

+ func (mr *MockdatabaseShardMockRecorder) FetchIndexChecksum(ctx, id, blockStart, nsCtx interface{}) *gomock.Call

+ func (mr *MockdatabaseShardMockRecorder) FetchReadMismatch(ctx, mismatchChecker, id, blockStart, nsCtx interface{}) *gomock.Call

type Namespace

+ ReadOnly func() bool

+ SetReadOnly func(value bool)

type NamespaceIndex

+ Bootstrapped func() bool

+ WideQuery func(ctx context.Context, query index.Query, collector chan *ident.IDBatch, ...) error

type Options

+ AdminClient func() client.AdminClient

+ IndexClaimsManager func() fs.IndexClaimsManager

+ SetAdminClient func(value client.AdminClient) Options

+ SetIndexClaimsManager func(value fs.IndexClaimsManager) Options

+ SetWideBatchSize func(value int) Options

+ WideBatchSize func() int

Oct 7, 2020

Changes in this version

+ type BackgroundProcess interface

+ Report func()

+ Start func()

+ Stop func()

+ type MockBackgroundProcess struct

+ func NewMockBackgroundProcess(ctrl *gomock.Controller) *MockBackgroundProcess

+ func (m *MockBackgroundProcess) EXPECT() *MockBackgroundProcessMockRecorder

+ func (m *MockBackgroundProcess) Report()

+ func (m *MockBackgroundProcess) Start()

+ func (m *MockBackgroundProcess) Stop()

+ type MockBackgroundProcessMockRecorder struct

+ func (mr *MockBackgroundProcessMockRecorder) Report() *gomock.Call

+ func (mr *MockBackgroundProcessMockRecorder) Start() *gomock.Call

+ func (mr *MockBackgroundProcessMockRecorder) Stop() *gomock.Call

type MockOptions

+ func (m *MockOptions) BackgroundProcessFns() []NewBackgroundProcessFn

+ func (m *MockOptions) SetBackgroundProcessFns(arg0 []NewBackgroundProcessFn) Options

type MockOptionsMockRecorder

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

+ func (mr *MockOptionsMockRecorder) SetBackgroundProcessFns(arg0 interface{}) *gomock.Call

type MockdatabaseMediator

+ func (m *MockdatabaseMediator) RegisterBackgroundProcess(process BackgroundProcess) error

type MockdatabaseMediatorMockRecorder

+ func (mr *MockdatabaseMediatorMockRecorder) RegisterBackgroundProcess(process interface{}) *gomock.Call

+ type NewBackgroundProcessFn func(Database, Options) (BackgroundProcess, error)

type Options

+ BackgroundProcessFns func() []NewBackgroundProcessFn

+ SetBackgroundProcessFns func([]NewBackgroundProcessFn) Options

Oct 2, 2020

Changes in this version

+ type GetNamespaceFn func(k ident.ID) (databaseNamespace, bool)

type MockNamespace

+ func (m *MockNamespace) SetIndex(reverseIndex NamespaceIndex) error

+ type MockNamespaceHooks struct

+ func NewMockNamespaceHooks(ctrl *gomock.Controller) *MockNamespaceHooks

+ func (m *MockNamespaceHooks) EXPECT() *MockNamespaceHooksMockRecorder

+ func (m *MockNamespaceHooks) OnCreatedNamespace(arg0 Namespace, arg1 GetNamespaceFn) error

+ type MockNamespaceHooksMockRecorder struct

+ func (mr *MockNamespaceHooksMockRecorder) OnCreatedNamespace(arg0, arg1 interface{}) *gomock.Call

type MockNamespaceIndex

+ func (m *MockNamespaceIndex) SetExtendedRetentionPeriod(period time.Duration)

type MockNamespaceIndexMockRecorder

+ func (mr *MockNamespaceIndexMockRecorder) SetExtendedRetentionPeriod(period interface{}) *gomock.Call

type MockNamespaceMockRecorder

+ func (mr *MockNamespaceMockRecorder) SetIndex(reverseIndex interface{}) *gomock.Call

type MockOptions

+ func (m *MockOptions) NamespaceHooks() NamespaceHooks

+ func (m *MockOptions) SetNamespaceHooks(hooks NamespaceHooks) Options

type MockOptionsMockRecorder

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

+ func (mr *MockOptionsMockRecorder) SetNamespaceHooks(hooks interface{}) *gomock.Call

type MockdatabaseNamespace

+ func (m *MockdatabaseNamespace) ReadableShardAt(shardID uint32) (databaseShard, namespace.Context, error)

+ func (m *MockdatabaseNamespace) SetIndex(reverseIndex NamespaceIndex) error

+ func (m *MockdatabaseNamespace) ShardBootstrapState() ShardBootstrapStates

type MockdatabaseNamespaceMockRecorder

+ func (mr *MockdatabaseNamespaceMockRecorder) ReadableShardAt(shardID interface{}) *gomock.Call

+ func (mr *MockdatabaseNamespaceMockRecorder) SetIndex(reverseIndex interface{}) *gomock.Call

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

type MockdatabaseShard

+ func (m *MockdatabaseShard) LatestVolume(blockStart time.Time) (int, error)

type MockdatabaseShardMockRecorder

+ func (mr *MockdatabaseShardMockRecorder) LatestVolume(blockStart interface{}) *gomock.Call

type Namespace

+ SetIndex func(reverseIndex NamespaceIndex) error

+ type NamespaceHooks interface

+ OnCreatedNamespace func(Namespace, GetNamespaceFn) error

type NamespaceIndex

+ func NewReadOnlyIndexProxy(underlying NamespaceIndex) NamespaceIndex

+ SetExtendedRetentionPeriod func(period time.Duration)

type Options

+ NamespaceHooks func() NamespaceHooks

+ SetNamespaceHooks func(hooks NamespaceHooks) Options

Sep 15, 2020

Changes in this version

+ type AggregateTilesOptions struct

+ End time.Time

+ HandleCounterResets bool

+ Start time.Time

+ Step time.Duration

+ func NewAggregateTilesOptions(start, end time.Time, step time.Duration, handleCounterResets bool) (AggregateTilesOptions, error)

type Database

+ AggregateTiles func(ctx context.Context, sourceNsID, targetNsID ident.ID, ...) (int64, error)

type MockDatabase

+ func (m *MockDatabase) AggregateTiles(ctx context.Context, sourceNsID, targetNsID ident.ID, ...) (int64, error)

type MockDatabaseMockRecorder

+ func (mr *MockDatabaseMockRecorder) AggregateTiles(ctx, sourceNsID, targetNsID, opts interface{}) *gomock.Call

type Mockdatabase

+ func (m *Mockdatabase) AggregateTiles(ctx context.Context, sourceNsID, targetNsID ident.ID, ...) (int64, error)

type MockdatabaseMockRecorder

+ func (mr *MockdatabaseMockRecorder) AggregateTiles(ctx, sourceNsID, targetNsID, opts interface{}) *gomock.Call

type MockdatabaseNamespace

+ func (m *MockdatabaseNamespace) AggregateTiles(ctx context.Context, sourceNs databaseNamespace, opts AggregateTilesOptions, ...) (int64, error)

type MockdatabaseNamespaceMockRecorder

+ func (mr *MockdatabaseNamespaceMockRecorder) AggregateTiles(ctx, sourceNs, opts, pm interface{}) *gomock.Call

type MockdatabaseShard

+ func (m *MockdatabaseShard) AggregateTiles(ctx context.Context, reader fs.DataFileSetReader, sourceNsID ident.ID, ...) (int64, error)

type MockdatabaseShardMockRecorder

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

+ type ShardSnapshotResult struct

+ SeriesPersist int

Aug 12, 2020

Changes in this version

type MockOptions

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

+ func (m *MockOptions) SetMediatorTickInterval(value time.Duration) Options

type MockOptionsMockRecorder

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

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

type Options

+ MediatorTickInterval func() time.Duration

+ SetMediatorTickInterval func(value time.Duration) Options

Aug 1, 2020

Changes in this version

type MockdatabaseCleanupManager

+ func (m *MockdatabaseCleanupManager) ColdFlushCleanup(t time.Time, isBootstrapped bool) error

+ func (m *MockdatabaseCleanupManager) WarmFlushCleanup(t time.Time, isBootstrapped bool) error

type MockdatabaseCleanupManagerMockRecorder

+ func (mr *MockdatabaseCleanupManagerMockRecorder) ColdFlushCleanup(t, isBootstrapped interface{}) *gomock.Call

+ func (mr *MockdatabaseCleanupManagerMockRecorder) WarmFlushCleanup(t, isBootstrapped interface{}) *gomock.Call

+ type MockdatabaseColdFlushManager struct

+ func NewMockdatabaseColdFlushManager(ctrl *gomock.Controller) *MockdatabaseColdFlushManager

+ func (m *MockdatabaseColdFlushManager) ColdFlushCleanup(t time.Time, isBootstrapped bool) error

+ func (m *MockdatabaseColdFlushManager) Disable() fileOpStatus

+ func (m *MockdatabaseColdFlushManager) EXPECT() *MockdatabaseColdFlushManagerMockRecorder

+ func (m *MockdatabaseColdFlushManager) Enable() fileOpStatus

+ func (m *MockdatabaseColdFlushManager) Report()

+ func (m *MockdatabaseColdFlushManager) Run(t time.Time) bool

+ func (m *MockdatabaseColdFlushManager) Status() fileOpStatus

+ func (m *MockdatabaseColdFlushManager) WarmFlushCleanup(t time.Time, isBootstrapped bool) error

+ type MockdatabaseColdFlushManagerMockRecorder struct

+ func (mr *MockdatabaseColdFlushManagerMockRecorder) ColdFlushCleanup(t, isBootstrapped interface{}) *gomock.Call

+ func (mr *MockdatabaseColdFlushManagerMockRecorder) Disable() *gomock.Call

+ func (mr *MockdatabaseColdFlushManagerMockRecorder) Enable() *gomock.Call

+ func (mr *MockdatabaseColdFlushManagerMockRecorder) Report() *gomock.Call

+ func (mr *MockdatabaseColdFlushManagerMockRecorder) Run(t interface{}) *gomock.Call

+ func (mr *MockdatabaseColdFlushManagerMockRecorder) Status() *gomock.Call

+ func (mr *MockdatabaseColdFlushManagerMockRecorder) WarmFlushCleanup(t, isBootstrapped interface{}) *gomock.Call

type MockdatabaseMediator

+ func (m *MockdatabaseMediator) DisableFileOpsAndWait()

type MockdatabaseMediatorMockRecorder

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

Jul 24, 2020

Changes in this version

type MockOptions

+ func (m *MockOptions) NamespaceRuntimeOptionsManagerRegistry() namespace.RuntimeOptionsManagerRegistry

+ func (m *MockOptions) SetNamespaceRuntimeOptionsManagerRegistry(value namespace.RuntimeOptionsManagerRegistry) Options

type MockOptionsMockRecorder

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

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

type MockdatabaseShard

+ func (m *MockdatabaseShard) DocRef(id ident.ID) (doc.Document, bool, error)

type MockdatabaseShardMockRecorder

+ func (mr *MockdatabaseShardMockRecorder) DocRef(id interface{}) *gomock.Call

type Options

+ NamespaceRuntimeOptionsManagerRegistry func() namespace.RuntimeOptionsManagerRegistry

+ SetNamespaceRuntimeOptionsManagerRegistry func(value namespace.RuntimeOptionsManagerRegistry) Options

Jul 1, 2020

Changes in this version

type MockNamespaceIndex

+ func (m *MockNamespaceIndex) WritePending(pending []writes.PendingIndexInsert) error

type MockNamespaceIndexMockRecorder

+ func (mr *MockNamespaceIndexMockRecorder) WritePending(pending interface{}) *gomock.Call

type MockdatabaseNamespace

+ func (m *MockdatabaseNamespace) WritePendingIndexInserts(pending []writes.PendingIndexInsert) error

type MockdatabaseNamespaceMockRecorder

+ func (mr *MockdatabaseNamespaceMockRecorder) WritePendingIndexInserts(pending interface{}) *gomock.Call

type MocknamespaceIndexInsertQueue

+ func (m *MocknamespaceIndexInsertQueue) InsertPending(pending []writes.PendingIndexInsert) (*sync.WaitGroup, error)

type MocknamespaceIndexInsertQueueMockRecorder

+ func (mr *MocknamespaceIndexInsertQueueMockRecorder) InsertPending(pending interface{}) *gomock.Call

type NamespaceIndex

+ WritePending func(pending []writes.PendingIndexInsert) error

+ type SeriesWrite struct

+ NeedsIndex bool

+ PendingIndexInsert writes.PendingIndexInsert

+ Series ts.Series

+ WasWritten bool

Jun 23, 2020

Changes in this version

+ type MockShardColdFlush struct

+ func NewMockShardColdFlush(ctrl *gomock.Controller) *MockShardColdFlush

+ func (m *MockShardColdFlush) Done() error

+ func (m *MockShardColdFlush) EXPECT() *MockShardColdFlushMockRecorder

+ type MockShardColdFlushMockRecorder struct

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

+ type ShardColdFlush interface

+ Done func() error

Jun 3, 2020

Changes in this version

+ func NewDatabaseNamespaceDataAccumulator(namespace databaseNamespace) bootstrap.NamespaceDataAccumulator

+ type BootstrapResult struct

+ AlreadyBootstrapping bool

+ ErrorsBootstrap []error

+ type DebugMemorySegmentsOptions struct

+ OutputDirectory string

type MockNamespace

+ func (m *MockNamespace) Index() (NamespaceIndex, error)

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

+ func (m *MockNamespace) StorageOptions() Options

+ 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) AssignShardSet(shardSet sharding.ShardSet)

+ func (m *MockNamespaceIndex) BlockForBlockStart(blockStart time.Time) (index.Block, 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) CleanupDuplicateFileSets() error

+ func (m *MockNamespaceIndex) CleanupExpiredFileSets(t time.Time) error

+ func (m *MockNamespaceIndex) Close() error

+ func (m *MockNamespaceIndex) ColdFlush(shards []databaseShard) (OnColdFlushDone, error)

+ func (m *MockNamespaceIndex) DebugMemorySegments(opts DebugMemorySegmentsOptions) error

+ func (m *MockNamespaceIndex) EXPECT() *MockNamespaceIndexMockRecorder

+ func (m *MockNamespaceIndex) Query(ctx context.Context, query index.Query, opts index.QueryOptions) (index.QueryResult, error)

+ func (m *MockNamespaceIndex) Tick(c context.Cancellable, startTime time.Time) (namespaceIndexTickResult, error)

+ func (m *MockNamespaceIndex) WarmFlush(flush persist.IndexFlush, shards []databaseShard) error

+ func (m *MockNamespaceIndex) WriteBatch(batch *index.WriteBatch) error

+ type MockNamespaceIndexMockRecorder struct

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

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

+ func (mr *MockNamespaceIndexMockRecorder) BlockForBlockStart(blockStart 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) CleanupDuplicateFileSets() *gomock.Call

+ func (mr *MockNamespaceIndexMockRecorder) CleanupExpiredFileSets(t interface{}) *gomock.Call

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

+ func (mr *MockNamespaceIndexMockRecorder) ColdFlush(shards interface{}) *gomock.Call

+ func (mr *MockNamespaceIndexMockRecorder) DebugMemorySegments(opts interface{}) *gomock.Call

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

+ func (mr *MockNamespaceIndexMockRecorder) Tick(c, startTime interface{}) *gomock.Call

+ func (mr *MockNamespaceIndexMockRecorder) WarmFlush(flush, shards interface{}) *gomock.Call

+ func (mr *MockNamespaceIndexMockRecorder) WriteBatch(batch interface{}) *gomock.Call

type MockNamespaceMockRecorder

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

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

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

+ type MockOnColdFlush struct

+ func NewMockOnColdFlush(ctrl *gomock.Controller) *MockOnColdFlush

+ func (m *MockOnColdFlush) ColdFlushNamespace(ns Namespace) (OnColdFlushNamespace, error)

+ func (m *MockOnColdFlush) EXPECT() *MockOnColdFlushMockRecorder

+ type MockOnColdFlushMockRecorder struct

+ func (mr *MockOnColdFlushMockRecorder) ColdFlushNamespace(ns interface{}) *gomock.Call

+ type MockOnColdFlushNamespace struct

+ func NewMockOnColdFlushNamespace(ctrl *gomock.Controller) *MockOnColdFlushNamespace

+ func (m *MockOnColdFlushNamespace) Done() error

+ func (m *MockOnColdFlushNamespace) EXPECT() *MockOnColdFlushNamespaceMockRecorder

+ func (m *MockOnColdFlushNamespace) OnFlushNewSeries(arg0 persist.OnFlushNewSeriesEvent) error

+ type MockOnColdFlushNamespaceMockRecorder struct

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

+ func (mr *MockOnColdFlushNamespaceMockRecorder) OnFlushNewSeries(arg0 interface{}) *gomock.Call

type MockOptions

+ func (m *MockOptions) CheckedBytesWrapperPool() xpool.CheckedBytesWrapperPool

+ func (m *MockOptions) DoNotIndexWithFieldsMap() map[string]string

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

+ func (m *MockOptions) OnColdFlush() OnColdFlush

+ func (m *MockOptions) RetrieveRequestPool() fs.RetrieveRequestPool

+ func (m *MockOptions) SetCheckedBytesWrapperPool(value xpool.CheckedBytesWrapperPool) Options

+ func (m *MockOptions) SetDoNotIndexWithFieldsMap(value map[string]string) Options

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

+ func (m *MockOptions) SetOnColdFlush(value OnColdFlush) Options

+ func (m *MockOptions) SetRetrieveRequestPool(value fs.RetrieveRequestPool) Options

type MockOptionsMockRecorder

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

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

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

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

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

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

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

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

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

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

type Mockdatabase

+ func (m *Mockdatabase) OwnedNamespaces() ([]databaseNamespace, error)

type MockdatabaseMediator

+ func (m *MockdatabaseMediator) WaitForFileSystemProcesses()

type MockdatabaseMediatorMockRecorder

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

type MockdatabaseMockRecorder

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

type MockdatabaseNamespace

+ func (m *MockdatabaseNamespace) Index() (NamespaceIndex, error)

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

+ func (m *MockdatabaseNamespace) OwnedShards() []databaseShard

+ func (m *MockdatabaseNamespace) PrepareBootstrap(ctx context.Context) ([]databaseShard, error)

+ func (m *MockdatabaseNamespace) SeriesReadWriteRef(shardID uint32, id ident.ID, tags ident.TagIterator) (SeriesReadWriteRef, bool, error)

+ func (m *MockdatabaseNamespace) StorageOptions() Options

type MockdatabaseNamespaceMockRecorder

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

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

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

+ func (mr *MockdatabaseNamespaceMockRecorder) PrepareBootstrap(ctx interface{}) *gomock.Call

+ func (mr *MockdatabaseNamespaceMockRecorder) SeriesReadWriteRef(shardID, id, tags interface{}) *gomock.Call

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

type MockdatabaseShard

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

+ func (m *MockdatabaseShard) PrepareBootstrap(ctx context.Context) error

+ func (m *MockdatabaseShard) SeriesReadWriteRef(id ident.ID, tags ident.TagIterator, opts ShardSeriesReadWriteRefOptions) (SeriesReadWriteRef, error)

+ func (m *MockdatabaseShard) UpdateFlushStates()

type MockdatabaseShardMockRecorder

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

+ func (mr *MockdatabaseShardMockRecorder) PrepareBootstrap(ctx interface{}) *gomock.Call

+ func (mr *MockdatabaseShardMockRecorder) SeriesReadWriteRef(id, tags, opts interface{}) *gomock.Call

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

type Namespace

+ Index func() (NamespaceIndex, error)

+ Metadata func() namespace.Metadata

+ StorageOptions func() Options

+ type NamespaceIndex interface

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

+ AssignShardSet func(shardSet sharding.ShardSet)

+ BlockForBlockStart func(blockStart time.Time) (index.Block, error)

+ BlockStartForWriteTime func(writeTime time.Time) xtime.UnixNano

+ Bootstrap func(bootstrapResults result.IndexResults) error

+ BootstrapsDone func() uint

+ CleanupDuplicateFileSets func() error

+ CleanupExpiredFileSets func(t time.Time) error

+ Close func() error

+ ColdFlush func(shards []databaseShard) (OnColdFlushDone, error)

+ DebugMemorySegments func(opts DebugMemorySegmentsOptions) error

+ Query func(ctx context.Context, query index.Query, opts index.QueryOptions) (index.QueryResult, error)

+ Tick func(c context.Cancellable, startTime time.Time) (namespaceIndexTickResult, error)

+ WarmFlush func(flush persist.IndexFlush, shards []databaseShard) error

+ WriteBatch func(batch *index.WriteBatch) error

+ type OnColdFlush interface

+ ColdFlushNamespace func(ns Namespace) (OnColdFlushNamespace, error)

+ type OnColdFlushDone func() error

+ type OnColdFlushNamespace interface

+ Done func() error

type Options

+ CheckedBytesWrapperPool func() xpool.CheckedBytesWrapperPool

+ DoNotIndexWithFieldsMap func() map[string]string

+ MmapReporter func() mmap.Reporter

+ OnColdFlush func() OnColdFlush

+ RetrieveRequestPool func() fs.RetrieveRequestPool

+ SetCheckedBytesWrapperPool func(value xpool.CheckedBytesWrapperPool) Options

+ SetDoNotIndexWithFieldsMap func(value map[string]string) Options

+ SetMmapReporter func(mmapReporter mmap.Reporter) Options

+ SetOnColdFlush func(value OnColdFlush) Options

+ SetRetrieveRequestPool func(value fs.RetrieveRequestPool) Options

+ type SeriesReadWriteRef struct

+ ReleaseReadWriteRef lookup.OnReleaseReadWriteRef

+ Series series.DatabaseSeries

+ Shard uint32

+ UniqueIndex uint64

+ type ShardSeriesReadWriteRefOptions struct

+ ReverseIndex bool

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