storage

package
v0.4.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 30, 2018 License: Apache-2.0 Imports: 56 Imported by: 10

Documentation

Overview

Package storage is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewSeriesOptionsFromOptions 

func NewSeriesOptionsFromOptions(opts Options, ropts retention.Options) series.Options

NewSeriesOptionsFromOptions creates a new set of database series options from provided options.

Types

type BootstrapState 

type BootstrapState int

BootstrapState is an enum representing the possible bootstrap states for a shard. 

const (
	// BootstrapNotStarted indicates bootstrap has not been started yet.
	BootstrapNotStarted BootstrapState = iota
	// Bootstrapping indicates bootstrap process is in progress.
	Bootstrapping
	// Bootstrapped indicates a bootstrap process has completed.
	Bootstrapped
)

type Database 

type Database interface {
	// Options returns the database options
	Options() Options

	// AssignShardSet sets the shard set assignment and returns immediately
	AssignShardSet(shardSet sharding.ShardSet)

	// Namespaces returns the namespaces
	Namespaces() []Namespace

	// Namespace returns the specified namespace
	Namespace(ns ident.ID) (Namespace, bool)

	// Open will open the database for writing and reading
	Open() error

	// Close will close the database for writing and reading. Close releases
	// release resources held by owned namespaces
	Close() error

	// ShardSet returns the set of shards currently associated with this namespace
	ShardSet() sharding.ShardSet

	// Terminate will close the database for writing and reading. Terminate does
	// NOT release any resources held by owned namespaces, instead relying upon
	// the GC to do so.
	Terminate() error

	// Write value to the database for an ID
	Write(
		ctx context.Context,
		namespace ident.ID,
		id ident.ID,
		timestamp time.Time,
		value float64,
		unit xtime.Unit,
		annotation []byte,
	) error

	// WriteTagged values to the database for an ID
	WriteTagged(
		ctx context.Context,
		namespace ident.ID,
		id ident.ID,
		tags ident.TagIterator,
		timestamp time.Time,
		value float64,
		unit xtime.Unit,
		annotation []byte,
	) error

	// QueryIDs resolves the given query into known IDs.
	QueryIDs(
		ctx context.Context,
		namespace ident.ID,
		query index.Query,
		opts index.QueryOptions,
	) (index.QueryResults, error)

	// ReadEncoded retrieves encoded segments for an ID
	ReadEncoded(
		ctx context.Context,
		namespace ident.ID,
		id ident.ID,
		start, end time.Time,
	) ([][]xio.BlockReader, error)

	// FetchBlocks retrieves data blocks for a given id and a list of block start times.
	FetchBlocks(
		ctx context.Context,
		namespace ident.ID,
		shard uint32,
		id ident.ID,
		starts []time.Time,
	) ([]block.FetchBlockResult, error)

	// FetchBlocksMetadata retrieves blocks metadata for a given shard, returns the
	// fetched block metadata results, the next page token, and any error encountered.
	// If we have fetched all the block metadata, we return nil as the next page token.
	FetchBlocksMetadata(
		ctx context.Context,
		namespace ident.ID,
		shard uint32,
		start, end time.Time,
		limit int64,
		pageToken int64,
		opts block.FetchBlocksMetadataOptions,
	) (block.FetchBlocksMetadataResults, *int64, error)

	// FetchBlocksMetadata retrieves blocks metadata for a given shard, returns the
	// fetched block metadata results, the next page token, and any error encountered.
	// If we have fetched all the block metadata, we return nil as the next page token.
	FetchBlocksMetadataV2(
		ctx context.Context,
		namespace ident.ID,
		shard uint32,
		start, end time.Time,
		limit int64,
		pageToken PageToken,
		opts block.FetchBlocksMetadataOptions,
	) (block.FetchBlocksMetadataResults, PageToken, error)

	// Bootstrap bootstraps the database.
	Bootstrap() error

	// IsBootstrapped determines whether the database is bootstrapped.
	IsBootstrapped() bool

	// IsOverloaded determines whether the database is overloaded
	IsOverloaded() bool

	// Repair will issue a repair and return nil on success or error on error.
	Repair() error

	// Truncate truncates data for the given namespace
	Truncate(namespace ident.ID) (int64, error)

	// BootstrapState captures and returns a snapshot of the databases' bootstrap state.
	BootstrapState() DatabaseBootstrapState
}

Database is a time series database

func NewDatabase 

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

NewDatabase creates a new time series database

type DatabaseBootstrapState 

type DatabaseBootstrapState struct {
	NamespaceBootstrapStates NamespaceBootstrapStates
}

DatabaseBootstrapState stores a snapshot of the bootstrap state for all shards across all namespaces at a given moment in time.

type MockDatabase 

type MockDatabase struct {
	// contains filtered or unexported fields
}

MockDatabase is a mock of Database interface

func NewMockDatabase 

func NewMockDatabase(ctrl *gomock.Controller) *MockDatabase

NewMockDatabase creates a new mock instance

func (*MockDatabase) AssignShardSet 

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

AssignShardSet mocks base method

func (*MockDatabase) Bootstrap 

func (m *MockDatabase) Bootstrap() error

Bootstrap mocks base method

func (*MockDatabase) BootstrapState 

func (m *MockDatabase) BootstrapState() DatabaseBootstrapState

BootstrapState mocks base method

func (*MockDatabase) Close 

func (m *MockDatabase) Close() error

Close mocks base method

func (*MockDatabase) EXPECT 

func (m *MockDatabase) EXPECT() *MockDatabaseMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockDatabase) FetchBlocks 

func (m *MockDatabase) FetchBlocks(ctx context.Context, namespace ident.ID, shard uint32, id ident.ID, starts []time.Time) ([]block.FetchBlockResult, error)

FetchBlocks mocks base method

func (*MockDatabase) FetchBlocksMetadata 

func (m *MockDatabase) FetchBlocksMetadata(ctx context.Context, namespace ident.ID, shard uint32, start, end time.Time, limit, pageToken int64, opts block.FetchBlocksMetadataOptions) (block.FetchBlocksMetadataResults, *int64, error)

FetchBlocksMetadata mocks base method

func (*MockDatabase) FetchBlocksMetadataV2 

func (m *MockDatabase) FetchBlocksMetadataV2(ctx context.Context, namespace ident.ID, shard uint32, start, end time.Time, limit int64, pageToken PageToken, opts block.FetchBlocksMetadataOptions) (block.FetchBlocksMetadataResults, PageToken, error)

FetchBlocksMetadataV2 mocks base method

func (*MockDatabase) IsBootstrapped 

func (m *MockDatabase) IsBootstrapped() bool

IsBootstrapped mocks base method

func (*MockDatabase) IsOverloaded 

func (m *MockDatabase) IsOverloaded() bool

IsOverloaded mocks base method

func (*MockDatabase) Namespace 

func (m *MockDatabase) Namespace(ns ident.ID) (Namespace, bool)

Namespace mocks base method

func (*MockDatabase) Namespaces 

func (m *MockDatabase) Namespaces() []Namespace

Namespaces mocks base method

func (*MockDatabase) Open 

func (m *MockDatabase) Open() error

Open mocks base method

func (*MockDatabase) Options 

func (m *MockDatabase) Options() Options

Options mocks base method

func (*MockDatabase) QueryIDs 

func (m *MockDatabase) QueryIDs(ctx context.Context, namespace ident.ID, query index.Query, opts index.QueryOptions) (index.QueryResults, error)

QueryIDs mocks base method

func (*MockDatabase) ReadEncoded 

func (m *MockDatabase) ReadEncoded(ctx context.Context, namespace, id ident.ID, start, end time.Time) ([][]xio.BlockReader, error)

ReadEncoded mocks base method

func (*MockDatabase) Repair 

func (m *MockDatabase) Repair() error

Repair mocks base method

func (*MockDatabase) ShardSet 

func (m *MockDatabase) ShardSet() sharding.ShardSet

ShardSet mocks base method

func (*MockDatabase) Terminate 

func (m *MockDatabase) Terminate() error

Terminate mocks base method

func (*MockDatabase) Truncate 

func (m *MockDatabase) Truncate(namespace ident.ID) (int64, error)

Truncate mocks base method

func (*MockDatabase) Write 

func (m *MockDatabase) Write(ctx context.Context, namespace, id ident.ID, timestamp time.Time, value float64, unit time0.Unit, annotation []byte) error

Write mocks base method

func (*MockDatabase) WriteTagged 

func (m *MockDatabase) WriteTagged(ctx context.Context, namespace, id ident.ID, tags ident.TagIterator, timestamp time.Time, value float64, unit time0.Unit, annotation []byte) error

WriteTagged mocks base method

type MockDatabaseMockRecorder 

type MockDatabaseMockRecorder struct {
	// contains filtered or unexported fields
}

MockDatabaseMockRecorder is the mock recorder for MockDatabase

func (*MockDatabaseMockRecorder) AssignShardSet 

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

AssignShardSet indicates an expected call of AssignShardSet

func (*MockDatabaseMockRecorder) Bootstrap 

func (mr *MockDatabaseMockRecorder) Bootstrap() *gomock.Call

Bootstrap indicates an expected call of Bootstrap

func (*MockDatabaseMockRecorder) BootstrapState 

func (mr *MockDatabaseMockRecorder) BootstrapState() *gomock.Call

BootstrapState indicates an expected call of BootstrapState

func (*MockDatabaseMockRecorder) Close 

func (mr *MockDatabaseMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close

func (*MockDatabaseMockRecorder) FetchBlocks 

func (mr *MockDatabaseMockRecorder) FetchBlocks(ctx, namespace, shard, id, starts interface{}) *gomock.Call

FetchBlocks indicates an expected call of FetchBlocks

func (*MockDatabaseMockRecorder) FetchBlocksMetadata 

func (mr *MockDatabaseMockRecorder) FetchBlocksMetadata(ctx, namespace, shard, start, end, limit, pageToken, opts interface{}) *gomock.Call

FetchBlocksMetadata indicates an expected call of FetchBlocksMetadata

func (*MockDatabaseMockRecorder) FetchBlocksMetadataV2 

func (mr *MockDatabaseMockRecorder) FetchBlocksMetadataV2(ctx, namespace, shard, start, end, limit, pageToken, opts interface{}) *gomock.Call

FetchBlocksMetadataV2 indicates an expected call of FetchBlocksMetadataV2

func (*MockDatabaseMockRecorder) IsBootstrapped 

func (mr *MockDatabaseMockRecorder) IsBootstrapped() *gomock.Call

IsBootstrapped indicates an expected call of IsBootstrapped

func (*MockDatabaseMockRecorder) IsOverloaded 

func (mr *MockDatabaseMockRecorder) IsOverloaded() *gomock.Call

IsOverloaded indicates an expected call of IsOverloaded

func (*MockDatabaseMockRecorder) Namespace 

func (mr *MockDatabaseMockRecorder) Namespace(ns interface{}) *gomock.Call

Namespace indicates an expected call of Namespace

func (*MockDatabaseMockRecorder) Namespaces 

func (mr *MockDatabaseMockRecorder) Namespaces() *gomock.Call

Namespaces indicates an expected call of Namespaces

func (*MockDatabaseMockRecorder) Open 

func (mr *MockDatabaseMockRecorder) Open() *gomock.Call

Open indicates an expected call of Open

func (*MockDatabaseMockRecorder) Options 

func (mr *MockDatabaseMockRecorder) Options() *gomock.Call

Options indicates an expected call of Options

func (*MockDatabaseMockRecorder) QueryIDs 

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

QueryIDs indicates an expected call of QueryIDs

func (*MockDatabaseMockRecorder) ReadEncoded 

func (mr *MockDatabaseMockRecorder) ReadEncoded(ctx, namespace, id, start, end interface{}) *gomock.Call

ReadEncoded indicates an expected call of ReadEncoded

func (*MockDatabaseMockRecorder) Repair 

func (mr *MockDatabaseMockRecorder) Repair() *gomock.Call

Repair indicates an expected call of Repair

func (*MockDatabaseMockRecorder) ShardSet 

func (mr *MockDatabaseMockRecorder) ShardSet() *gomock.Call

ShardSet indicates an expected call of ShardSet

func (*MockDatabaseMockRecorder) Terminate 

func (mr *MockDatabaseMockRecorder) Terminate() *gomock.Call

Terminate indicates an expected call of Terminate

func (*MockDatabaseMockRecorder) Truncate 

func (mr *MockDatabaseMockRecorder) Truncate(namespace interface{}) *gomock.Call

Truncate indicates an expected call of Truncate

func (*MockDatabaseMockRecorder) Write 

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

Write indicates an expected call of Write

func (*MockDatabaseMockRecorder) WriteTagged 

func (mr *MockDatabaseMockRecorder) WriteTagged(ctx, namespace, id, tags, timestamp, value, unit, annotation interface{}) *gomock.Call

WriteTagged indicates an expected call of WriteTagged

type MockNamespace 

type MockNamespace struct {
	// contains filtered or unexported fields
}

MockNamespace is a mock of Namespace interface

func NewMockNamespace 

func NewMockNamespace(ctrl *gomock.Controller) *MockNamespace

NewMockNamespace creates a new mock instance

func (*MockNamespace) EXPECT 

func (m *MockNamespace) EXPECT() *MockNamespaceMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockNamespace) ID 

func (m *MockNamespace) ID() ident.ID

ID mocks base method

func (*MockNamespace) NumSeries 

func (m *MockNamespace) NumSeries() int64

NumSeries mocks base method

func (*MockNamespace) Options 

func (m *MockNamespace) Options() namespace.Options

Options mocks base method

func (*MockNamespace) Shards 

func (m *MockNamespace) Shards() []Shard

Shards mocks base method

type MockNamespaceMockRecorder 

type MockNamespaceMockRecorder struct {
	// contains filtered or unexported fields
}

MockNamespaceMockRecorder is the mock recorder for MockNamespace

func (*MockNamespaceMockRecorder) ID 

func (mr *MockNamespaceMockRecorder) ID() *gomock.Call

ID indicates an expected call of ID

func (*MockNamespaceMockRecorder) NumSeries 

func (mr *MockNamespaceMockRecorder) NumSeries() *gomock.Call

NumSeries indicates an expected call of NumSeries

func (*MockNamespaceMockRecorder) Options 

func (mr *MockNamespaceMockRecorder) Options() *gomock.Call

Options indicates an expected call of Options

func (*MockNamespaceMockRecorder) Shards 

func (mr *MockNamespaceMockRecorder) Shards() *gomock.Call

Shards indicates an expected call of Shards

type MockOptions 

type MockOptions struct {
	// contains filtered or unexported fields
}

MockOptions is a mock of Options interface

func NewMockOptions 

func NewMockOptions(ctrl *gomock.Controller) *MockOptions

NewMockOptions creates a new mock instance

func (*MockOptions) BootstrapProcessProvider 

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

BootstrapProcessProvider mocks base method

func (*MockOptions) BytesPool 

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

BytesPool mocks base method

func (*MockOptions) ClockOptions 

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

ClockOptions mocks base method

func (*MockOptions) CommitLogOptions 

func (m *MockOptions) CommitLogOptions() commitlog.Options

CommitLogOptions mocks base method

func (*MockOptions) ContextPool 

func (m *MockOptions) ContextPool() context.Pool

ContextPool mocks base method

func (*MockOptions) DatabaseBlockOptions 

func (m *MockOptions) DatabaseBlockOptions() block.Options

DatabaseBlockOptions mocks base method

func (*MockOptions) DatabaseBlockRetrieverManager 

func (m *MockOptions) DatabaseBlockRetrieverManager() block.DatabaseBlockRetrieverManager

DatabaseBlockRetrieverManager mocks base method

func (*MockOptions) DatabaseSeriesPool 

func (m *MockOptions) DatabaseSeriesPool() series.DatabaseSeriesPool

DatabaseSeriesPool mocks base method

func (*MockOptions) EXPECT 

func (m *MockOptions) EXPECT() *MockOptionsMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockOptions) EncoderPool 

func (m *MockOptions) EncoderPool() encoding.EncoderPool

EncoderPool mocks base method

func (*MockOptions) ErrorCounterOptions 

func (m *MockOptions) ErrorCounterOptions() xcounter.Options

ErrorCounterOptions mocks base method

func (*MockOptions) ErrorThresholdForLoad 

func (m *MockOptions) ErrorThresholdForLoad() int64

ErrorThresholdForLoad mocks base method

func (*MockOptions) ErrorWindowForLoad 

func (m *MockOptions) ErrorWindowForLoad() time.Duration

ErrorWindowForLoad mocks base method

func (*MockOptions) FetchBlockMetadataResultsPool 

func (m *MockOptions) FetchBlockMetadataResultsPool() block.FetchBlockMetadataResultsPool

FetchBlockMetadataResultsPool mocks base method

func (*MockOptions) FetchBlocksMetadataResultsPool 

func (m *MockOptions) FetchBlocksMetadataResultsPool() block.FetchBlocksMetadataResultsPool

FetchBlocksMetadataResultsPool mocks base method

func (*MockOptions) IdentifierPool 

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

IdentifierPool mocks base method

func (*MockOptions) IndexOptions 

func (m *MockOptions) IndexOptions() index.Options

IndexOptions mocks base method

func (*MockOptions) InstrumentOptions 

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

InstrumentOptions mocks base method

func (*MockOptions) MinimumSnapshotInterval 

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

MinimumSnapshotInterval mocks base method

func (*MockOptions) MultiReaderIteratorPool 

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

MultiReaderIteratorPool mocks base method

func (*MockOptions) NamespaceInitializer 

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

NamespaceInitializer mocks base method

func (*MockOptions) PersistManager 

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

PersistManager mocks base method

func (*MockOptions) QueryIDsWorkerPool added in v0.3.0 

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

QueryIDsWorkerPool mocks base method

func (*MockOptions) ReaderIteratorPool 

func (m *MockOptions) ReaderIteratorPool() encoding.ReaderIteratorPool

ReaderIteratorPool mocks base method

func (*MockOptions) RepairEnabled 

func (m *MockOptions) RepairEnabled() bool

RepairEnabled mocks base method

func (*MockOptions) RepairOptions 

func (m *MockOptions) RepairOptions() repair.Options

RepairOptions mocks base method

func (*MockOptions) RuntimeOptionsManager 

func (m *MockOptions) RuntimeOptionsManager() runtime.OptionsManager

RuntimeOptionsManager mocks base method

func (*MockOptions) SegmentReaderPool 

func (m *MockOptions) SegmentReaderPool() xio.SegmentReaderPool

SegmentReaderPool mocks base method

func (*MockOptions) SeriesCachePolicy 

func (m *MockOptions) SeriesCachePolicy() series.CachePolicy

SeriesCachePolicy mocks base method

func (*MockOptions) SeriesOptions 

func (m *MockOptions) SeriesOptions() series.Options

SeriesOptions mocks base method

func (*MockOptions) SetBootstrapProcessProvider 

func (m *MockOptions) SetBootstrapProcessProvider(value bootstrap.ProcessProvider) Options

SetBootstrapProcessProvider mocks base method

func (*MockOptions) SetBytesPool 

func (m *MockOptions) SetBytesPool(value pool.CheckedBytesPool) Options

SetBytesPool mocks base method

func (*MockOptions) SetClockOptions 

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

SetClockOptions mocks base method

func (*MockOptions) SetCommitLogOptions 

func (m *MockOptions) SetCommitLogOptions(value commitlog.Options) Options

SetCommitLogOptions mocks base method

func (*MockOptions) SetContextPool 

func (m *MockOptions) SetContextPool(value context.Pool) Options

SetContextPool mocks base method

func (*MockOptions) SetDatabaseBlockOptions 

func (m *MockOptions) SetDatabaseBlockOptions(value block.Options) Options

SetDatabaseBlockOptions mocks base method

func (*MockOptions) SetDatabaseBlockRetrieverManager 

func (m *MockOptions) SetDatabaseBlockRetrieverManager(value block.DatabaseBlockRetrieverManager) Options

SetDatabaseBlockRetrieverManager mocks base method

func (*MockOptions) SetDatabaseSeriesPool 

func (m *MockOptions) SetDatabaseSeriesPool(value series.DatabaseSeriesPool) Options

SetDatabaseSeriesPool mocks base method

func (*MockOptions) SetEncoderPool 

func (m *MockOptions) SetEncoderPool(value encoding.EncoderPool) Options

SetEncoderPool mocks base method

func (*MockOptions) SetEncodingM3TSZPooled 

func (m *MockOptions) SetEncodingM3TSZPooled() Options

SetEncodingM3TSZPooled mocks base method

func (*MockOptions) SetErrorCounterOptions 

func (m *MockOptions) SetErrorCounterOptions(value xcounter.Options) Options

SetErrorCounterOptions mocks base method

func (*MockOptions) SetErrorThresholdForLoad 

func (m *MockOptions) SetErrorThresholdForLoad(value int64) Options

SetErrorThresholdForLoad mocks base method

func (*MockOptions) SetErrorWindowForLoad 

func (m *MockOptions) SetErrorWindowForLoad(value time.Duration) Options

SetErrorWindowForLoad mocks base method

func (*MockOptions) SetFetchBlockMetadataResultsPool 

func (m *MockOptions) SetFetchBlockMetadataResultsPool(value block.FetchBlockMetadataResultsPool) Options

SetFetchBlockMetadataResultsPool mocks base method

func (*MockOptions) SetFetchBlocksMetadataResultsPool 

func (m *MockOptions) SetFetchBlocksMetadataResultsPool(value block.FetchBlocksMetadataResultsPool) Options

SetFetchBlocksMetadataResultsPool mocks base method

func (*MockOptions) SetIdentifierPool 

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

SetIdentifierPool mocks base method

func (*MockOptions) SetIndexOptions 

func (m *MockOptions) SetIndexOptions(value index.Options) Options

SetIndexOptions mocks base method

func (*MockOptions) SetInstrumentOptions 

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

SetInstrumentOptions mocks base method

func (*MockOptions) SetMinimumSnapshotInterval 

func (m *MockOptions) SetMinimumSnapshotInterval(value time.Duration) Options

SetMinimumSnapshotInterval mocks base method

func (*MockOptions) SetMultiReaderIteratorPool 

func (m *MockOptions) SetMultiReaderIteratorPool(value encoding.MultiReaderIteratorPool) Options

SetMultiReaderIteratorPool mocks base method

func (*MockOptions) SetNamespaceInitializer 

func (m *MockOptions) SetNamespaceInitializer(value namespace.Initializer) Options

SetNamespaceInitializer mocks base method

func (*MockOptions) SetPersistManager 

func (m *MockOptions) SetPersistManager(value persist.Manager) Options

SetPersistManager mocks base method

func (*MockOptions) SetQueryIDsWorkerPool added in v0.3.0 

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

SetQueryIDsWorkerPool mocks base method

func (*MockOptions) SetReaderIteratorPool 

func (m *MockOptions) SetReaderIteratorPool(value encoding.ReaderIteratorPool) Options

SetReaderIteratorPool mocks base method

func (*MockOptions) SetRepairEnabled 

func (m *MockOptions) SetRepairEnabled(b bool) Options

SetRepairEnabled mocks base method

func (*MockOptions) SetRepairOptions 

func (m *MockOptions) SetRepairOptions(value repair.Options) Options

SetRepairOptions mocks base method

func (*MockOptions) SetRuntimeOptionsManager 

func (m *MockOptions) SetRuntimeOptionsManager(value runtime.OptionsManager) Options

SetRuntimeOptionsManager mocks base method

func (*MockOptions) SetSegmentReaderPool 

func (m *MockOptions) SetSegmentReaderPool(value xio.SegmentReaderPool) Options

SetSegmentReaderPool mocks base method

func (*MockOptions) SetSeriesCachePolicy 

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

SetSeriesCachePolicy mocks base method

func (*MockOptions) SetSeriesOptions 

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

SetSeriesOptions mocks base method

func (*MockOptions) Validate 

func (m *MockOptions) Validate() error

Validate mocks base method

type MockOptionsMockRecorder 

type MockOptionsMockRecorder struct {
	// contains filtered or unexported fields
}

MockOptionsMockRecorder is the mock recorder for MockOptions

func (*MockOptionsMockRecorder) BootstrapProcessProvider 

func (mr *MockOptionsMockRecorder) BootstrapProcessProvider() *gomock.Call

BootstrapProcessProvider indicates an expected call of BootstrapProcessProvider

func (*MockOptionsMockRecorder) BytesPool 

func (mr *MockOptionsMockRecorder) BytesPool() *gomock.Call

BytesPool indicates an expected call of BytesPool

func (*MockOptionsMockRecorder) ClockOptions 

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

ClockOptions indicates an expected call of ClockOptions

func (*MockOptionsMockRecorder) CommitLogOptions 

func (mr *MockOptionsMockRecorder) CommitLogOptions() *gomock.Call

CommitLogOptions indicates an expected call of CommitLogOptions

func (*MockOptionsMockRecorder) ContextPool 

func (mr *MockOptionsMockRecorder) ContextPool() *gomock.Call

ContextPool indicates an expected call of ContextPool

func (*MockOptionsMockRecorder) DatabaseBlockOptions 

func (mr *MockOptionsMockRecorder) DatabaseBlockOptions() *gomock.Call

DatabaseBlockOptions indicates an expected call of DatabaseBlockOptions

func (*MockOptionsMockRecorder) DatabaseBlockRetrieverManager 

func (mr *MockOptionsMockRecorder) DatabaseBlockRetrieverManager() *gomock.Call

DatabaseBlockRetrieverManager indicates an expected call of DatabaseBlockRetrieverManager

func (*MockOptionsMockRecorder) DatabaseSeriesPool 

func (mr *MockOptionsMockRecorder) DatabaseSeriesPool() *gomock.Call

DatabaseSeriesPool indicates an expected call of DatabaseSeriesPool

func (*MockOptionsMockRecorder) EncoderPool 

func (mr *MockOptionsMockRecorder) EncoderPool() *gomock.Call

EncoderPool indicates an expected call of EncoderPool

func (*MockOptionsMockRecorder) ErrorCounterOptions 

func (mr *MockOptionsMockRecorder) ErrorCounterOptions() *gomock.Call

ErrorCounterOptions indicates an expected call of ErrorCounterOptions

func (*MockOptionsMockRecorder) ErrorThresholdForLoad 

func (mr *MockOptionsMockRecorder) ErrorThresholdForLoad() *gomock.Call

ErrorThresholdForLoad indicates an expected call of ErrorThresholdForLoad

func (*MockOptionsMockRecorder) ErrorWindowForLoad 

func (mr *MockOptionsMockRecorder) ErrorWindowForLoad() *gomock.Call

ErrorWindowForLoad indicates an expected call of ErrorWindowForLoad

func (*MockOptionsMockRecorder) FetchBlockMetadataResultsPool 

func (mr *MockOptionsMockRecorder) FetchBlockMetadataResultsPool() *gomock.Call

FetchBlockMetadataResultsPool indicates an expected call of FetchBlockMetadataResultsPool

func (*MockOptionsMockRecorder) FetchBlocksMetadataResultsPool 

func (mr *MockOptionsMockRecorder) FetchBlocksMetadataResultsPool() *gomock.Call

FetchBlocksMetadataResultsPool indicates an expected call of FetchBlocksMetadataResultsPool

func (*MockOptionsMockRecorder) IdentifierPool 

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

IdentifierPool indicates an expected call of IdentifierPool

func (*MockOptionsMockRecorder) IndexOptions 

func (mr *MockOptionsMockRecorder) IndexOptions() *gomock.Call

IndexOptions indicates an expected call of IndexOptions

func (*MockOptionsMockRecorder) InstrumentOptions 

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

InstrumentOptions indicates an expected call of InstrumentOptions

func (*MockOptionsMockRecorder) MinimumSnapshotInterval 

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

MinimumSnapshotInterval indicates an expected call of MinimumSnapshotInterval

func (*MockOptionsMockRecorder) MultiReaderIteratorPool 

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

MultiReaderIteratorPool indicates an expected call of MultiReaderIteratorPool

func (*MockOptionsMockRecorder) NamespaceInitializer 

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

NamespaceInitializer indicates an expected call of NamespaceInitializer

func (*MockOptionsMockRecorder) PersistManager 

func (mr *MockOptionsMockRecorder) PersistManager() *gomock.Call

PersistManager indicates an expected call of PersistManager

func (*MockOptionsMockRecorder) QueryIDsWorkerPool added in v0.3.0 

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

QueryIDsWorkerPool indicates an expected call of QueryIDsWorkerPool

func (*MockOptionsMockRecorder) ReaderIteratorPool 

func (mr *MockOptionsMockRecorder) ReaderIteratorPool() *gomock.Call

ReaderIteratorPool indicates an expected call of ReaderIteratorPool

func (*MockOptionsMockRecorder) RepairEnabled 

func (mr *MockOptionsMockRecorder) RepairEnabled() *gomock.Call

RepairEnabled indicates an expected call of RepairEnabled

func (*MockOptionsMockRecorder) RepairOptions 

func (mr *MockOptionsMockRecorder) RepairOptions() *gomock.Call

RepairOptions indicates an expected call of RepairOptions

func (*MockOptionsMockRecorder) RuntimeOptionsManager 

func (mr *MockOptionsMockRecorder) RuntimeOptionsManager() *gomock.Call

RuntimeOptionsManager indicates an expected call of RuntimeOptionsManager

func (*MockOptionsMockRecorder) SegmentReaderPool 

func (mr *MockOptionsMockRecorder) SegmentReaderPool() *gomock.Call

SegmentReaderPool indicates an expected call of SegmentReaderPool

func (*MockOptionsMockRecorder) SeriesCachePolicy 

func (mr *MockOptionsMockRecorder) SeriesCachePolicy() *gomock.Call

SeriesCachePolicy indicates an expected call of SeriesCachePolicy

func (*MockOptionsMockRecorder) SeriesOptions 

func (mr *MockOptionsMockRecorder) SeriesOptions() *gomock.Call

SeriesOptions indicates an expected call of SeriesOptions

func (*MockOptionsMockRecorder) SetBootstrapProcessProvider 

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

SetBootstrapProcessProvider indicates an expected call of SetBootstrapProcessProvider

func (*MockOptionsMockRecorder) SetBytesPool 

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

SetBytesPool indicates an expected call of SetBytesPool

func (*MockOptionsMockRecorder) SetClockOptions 

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

SetClockOptions indicates an expected call of SetClockOptions

func (*MockOptionsMockRecorder) SetCommitLogOptions 

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

SetCommitLogOptions indicates an expected call of SetCommitLogOptions

func (*MockOptionsMockRecorder) SetContextPool 

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

SetContextPool indicates an expected call of SetContextPool

func (*MockOptionsMockRecorder) SetDatabaseBlockOptions 

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

SetDatabaseBlockOptions indicates an expected call of SetDatabaseBlockOptions

func (*MockOptionsMockRecorder) SetDatabaseBlockRetrieverManager 

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

SetDatabaseBlockRetrieverManager indicates an expected call of SetDatabaseBlockRetrieverManager

func (*MockOptionsMockRecorder) SetDatabaseSeriesPool 

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

SetDatabaseSeriesPool indicates an expected call of SetDatabaseSeriesPool

func (*MockOptionsMockRecorder) SetEncoderPool 

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

SetEncoderPool indicates an expected call of SetEncoderPool

func (*MockOptionsMockRecorder) SetEncodingM3TSZPooled 

func (mr *MockOptionsMockRecorder) SetEncodingM3TSZPooled() *gomock.Call

SetEncodingM3TSZPooled indicates an expected call of SetEncodingM3TSZPooled

func (*MockOptionsMockRecorder) SetErrorCounterOptions 

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

SetErrorCounterOptions indicates an expected call of SetErrorCounterOptions

func (*MockOptionsMockRecorder) SetErrorThresholdForLoad 

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

SetErrorThresholdForLoad indicates an expected call of SetErrorThresholdForLoad

func (*MockOptionsMockRecorder) SetErrorWindowForLoad 

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

SetErrorWindowForLoad indicates an expected call of SetErrorWindowForLoad

func (*MockOptionsMockRecorder) SetFetchBlockMetadataResultsPool 

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

SetFetchBlockMetadataResultsPool indicates an expected call of SetFetchBlockMetadataResultsPool

func (*MockOptionsMockRecorder) SetFetchBlocksMetadataResultsPool 

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

SetFetchBlocksMetadataResultsPool indicates an expected call of SetFetchBlocksMetadataResultsPool

func (*MockOptionsMockRecorder) SetIdentifierPool 

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

SetIdentifierPool indicates an expected call of SetIdentifierPool

func (*MockOptionsMockRecorder) SetIndexOptions 

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

SetIndexOptions indicates an expected call of SetIndexOptions

func (*MockOptionsMockRecorder) SetInstrumentOptions 

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

SetInstrumentOptions indicates an expected call of SetInstrumentOptions

func (*MockOptionsMockRecorder) SetMinimumSnapshotInterval 

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

SetMinimumSnapshotInterval indicates an expected call of SetMinimumSnapshotInterval

func (*MockOptionsMockRecorder) SetMultiReaderIteratorPool 

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

SetMultiReaderIteratorPool indicates an expected call of SetMultiReaderIteratorPool

func (*MockOptionsMockRecorder) SetNamespaceInitializer 

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

SetNamespaceInitializer indicates an expected call of SetNamespaceInitializer

func (*MockOptionsMockRecorder) SetPersistManager 

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

SetPersistManager indicates an expected call of SetPersistManager

func (*MockOptionsMockRecorder) SetQueryIDsWorkerPool added in v0.3.0 

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

SetQueryIDsWorkerPool indicates an expected call of SetQueryIDsWorkerPool

func (*MockOptionsMockRecorder) SetReaderIteratorPool 

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

SetReaderIteratorPool indicates an expected call of SetReaderIteratorPool

func (*MockOptionsMockRecorder) SetRepairEnabled 

func (mr *MockOptionsMockRecorder) SetRepairEnabled(b interface{}) *gomock.Call

SetRepairEnabled indicates an expected call of SetRepairEnabled

func (*MockOptionsMockRecorder) SetRepairOptions 

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

SetRepairOptions indicates an expected call of SetRepairOptions

func (*MockOptionsMockRecorder) SetRuntimeOptionsManager 

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

SetRuntimeOptionsManager indicates an expected call of SetRuntimeOptionsManager

func (*MockOptionsMockRecorder) SetSegmentReaderPool 

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

SetSegmentReaderPool indicates an expected call of SetSegmentReaderPool

func (*MockOptionsMockRecorder) SetSeriesCachePolicy 

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

SetSeriesCachePolicy indicates an expected call of SetSeriesCachePolicy

func (*MockOptionsMockRecorder) SetSeriesOptions 

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

SetSeriesOptions indicates an expected call of SetSeriesOptions

func (*MockOptionsMockRecorder) Validate 

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

Validate indicates an expected call of Validate

type MockShard 

type MockShard struct {
	// contains filtered or unexported fields
}

MockShard is a mock of Shard interface

func NewMockShard 

func NewMockShard(ctrl *gomock.Controller) *MockShard

NewMockShard creates a new mock instance

func (*MockShard) BootstrapState 

func (m *MockShard) BootstrapState() BootstrapState

BootstrapState mocks base method

func (*MockShard) EXPECT 

func (m *MockShard) EXPECT() *MockShardMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockShard) ID 

func (m *MockShard) ID() uint32

ID mocks base method

func (*MockShard) IsBootstrapped 

func (m *MockShard) IsBootstrapped() bool

IsBootstrapped mocks base method

func (*MockShard) NumSeries 

func (m *MockShard) NumSeries() int64

NumSeries mocks base method

type MockShardMockRecorder 

type MockShardMockRecorder struct {
	// contains filtered or unexported fields
}

MockShardMockRecorder is the mock recorder for MockShard

func (*MockShardMockRecorder) BootstrapState 

func (mr *MockShardMockRecorder) BootstrapState() *gomock.Call

BootstrapState indicates an expected call of BootstrapState

func (*MockShardMockRecorder) ID 

func (mr *MockShardMockRecorder) ID() *gomock.Call

ID indicates an expected call of ID

func (*MockShardMockRecorder) IsBootstrapped 

func (mr *MockShardMockRecorder) IsBootstrapped() *gomock.Call

IsBootstrapped indicates an expected call of IsBootstrapped

func (*MockShardMockRecorder) NumSeries 

func (mr *MockShardMockRecorder) NumSeries() *gomock.Call

NumSeries indicates an expected call of NumSeries

type Mockdatabase 

type Mockdatabase struct {
	// contains filtered or unexported fields
}

Mockdatabase is a mock of database interface

func NewMockdatabase 

func NewMockdatabase(ctrl *gomock.Controller) *Mockdatabase

NewMockdatabase creates a new mock instance

func (*Mockdatabase) AssignShardSet 

func (m *Mockdatabase) AssignShardSet(shardSet sharding.ShardSet)

AssignShardSet mocks base method

func (*Mockdatabase) Bootstrap 

func (m *Mockdatabase) Bootstrap() error

Bootstrap mocks base method

func (*Mockdatabase) BootstrapState 

func (m *Mockdatabase) BootstrapState() DatabaseBootstrapState

BootstrapState mocks base method

func (*Mockdatabase) Close 

func (m *Mockdatabase) Close() error

Close mocks base method

func (*Mockdatabase) EXPECT 

func (m *Mockdatabase) EXPECT() *MockdatabaseMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*Mockdatabase) FetchBlocks 

func (m *Mockdatabase) FetchBlocks(ctx context.Context, namespace ident.ID, shard uint32, id ident.ID, starts []time.Time) ([]block.FetchBlockResult, error)

FetchBlocks mocks base method

func (*Mockdatabase) FetchBlocksMetadata 

func (m *Mockdatabase) FetchBlocksMetadata(ctx context.Context, namespace ident.ID, shard uint32, start, end time.Time, limit, pageToken int64, opts block.FetchBlocksMetadataOptions) (block.FetchBlocksMetadataResults, *int64, error)

FetchBlocksMetadata mocks base method

func (*Mockdatabase) FetchBlocksMetadataV2 

func (m *Mockdatabase) FetchBlocksMetadataV2(ctx context.Context, namespace ident.ID, shard uint32, start, end time.Time, limit int64, pageToken PageToken, opts block.FetchBlocksMetadataOptions) (block.FetchBlocksMetadataResults, PageToken, error)

FetchBlocksMetadataV2 mocks base method

func (*Mockdatabase) GetOwnedNamespaces 

func (m *Mockdatabase) GetOwnedNamespaces() ([]databaseNamespace, error)

GetOwnedNamespaces mocks base method

func (*Mockdatabase) IsBootstrapped 

func (m *Mockdatabase) IsBootstrapped() bool

IsBootstrapped mocks base method

func (*Mockdatabase) IsOverloaded 

func (m *Mockdatabase) IsOverloaded() bool

IsOverloaded mocks base method

func (*Mockdatabase) Namespace 

func (m *Mockdatabase) Namespace(ns ident.ID) (Namespace, bool)

Namespace mocks base method

func (*Mockdatabase) Namespaces 

func (m *Mockdatabase) Namespaces() []Namespace

Namespaces mocks base method

func (*Mockdatabase) Open 

func (m *Mockdatabase) Open() error

Open mocks base method

func (*Mockdatabase) Options 

func (m *Mockdatabase) Options() Options

Options mocks base method

func (*Mockdatabase) QueryIDs 

func (m *Mockdatabase) QueryIDs(ctx context.Context, namespace ident.ID, query index.Query, opts index.QueryOptions) (index.QueryResults, error)

QueryIDs mocks base method

func (*Mockdatabase) ReadEncoded 

func (m *Mockdatabase) ReadEncoded(ctx context.Context, namespace, id ident.ID, start, end time.Time) ([][]xio.BlockReader, error)

ReadEncoded mocks base method

func (*Mockdatabase) Repair 

func (m *Mockdatabase) Repair() error

Repair mocks base method

func (*Mockdatabase) ShardSet 

func (m *Mockdatabase) ShardSet() sharding.ShardSet

ShardSet mocks base method

func (*Mockdatabase) Terminate 

func (m *Mockdatabase) Terminate() error

Terminate mocks base method

func (*Mockdatabase) Truncate 

func (m *Mockdatabase) Truncate(namespace ident.ID) (int64, error)

Truncate mocks base method

func (*Mockdatabase) UpdateOwnedNamespaces 

func (m *Mockdatabase) UpdateOwnedNamespaces(namespaces namespace.Map) error

UpdateOwnedNamespaces mocks base method

func (*Mockdatabase) Write 

func (m *Mockdatabase) Write(ctx context.Context, namespace, id ident.ID, timestamp time.Time, value float64, unit time0.Unit, annotation []byte) error

Write mocks base method

func (*Mockdatabase) WriteTagged 

func (m *Mockdatabase) WriteTagged(ctx context.Context, namespace, id ident.ID, tags ident.TagIterator, timestamp time.Time, value float64, unit time0.Unit, annotation []byte) error

WriteTagged mocks base method

type MockdatabaseBootstrapManager 

type MockdatabaseBootstrapManager struct {
	// contains filtered or unexported fields
}

MockdatabaseBootstrapManager is a mock of databaseBootstrapManager interface

func NewMockdatabaseBootstrapManager 

func NewMockdatabaseBootstrapManager(ctrl *gomock.Controller) *MockdatabaseBootstrapManager

NewMockdatabaseBootstrapManager creates a new mock instance

func (*MockdatabaseBootstrapManager) Bootstrap 

func (m *MockdatabaseBootstrapManager) Bootstrap() error

Bootstrap mocks base method

func (*MockdatabaseBootstrapManager) EXPECT 

func (m *MockdatabaseBootstrapManager) EXPECT() *MockdatabaseBootstrapManagerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockdatabaseBootstrapManager) IsBootstrapped 

func (m *MockdatabaseBootstrapManager) IsBootstrapped() bool

IsBootstrapped mocks base method

func (*MockdatabaseBootstrapManager) Report 

func (m *MockdatabaseBootstrapManager) Report()

Report mocks base method

type MockdatabaseBootstrapManagerMockRecorder 

type MockdatabaseBootstrapManagerMockRecorder struct {
	// contains filtered or unexported fields
}

MockdatabaseBootstrapManagerMockRecorder is the mock recorder for MockdatabaseBootstrapManager

func (*MockdatabaseBootstrapManagerMockRecorder) Bootstrap 

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

Bootstrap indicates an expected call of Bootstrap

func (*MockdatabaseBootstrapManagerMockRecorder) IsBootstrapped 

func (mr *MockdatabaseBootstrapManagerMockRecorder) IsBootstrapped() *gomock.Call

IsBootstrapped indicates an expected call of IsBootstrapped

func (*MockdatabaseBootstrapManagerMockRecorder) Report 

func (mr *MockdatabaseBootstrapManagerMockRecorder) Report() *gomock.Call

Report indicates an expected call of Report

type MockdatabaseCleanupManager 

type MockdatabaseCleanupManager struct {
	// contains filtered or unexported fields
}

MockdatabaseCleanupManager is a mock of databaseCleanupManager interface

func NewMockdatabaseCleanupManager 

func NewMockdatabaseCleanupManager(ctrl *gomock.Controller) *MockdatabaseCleanupManager

NewMockdatabaseCleanupManager creates a new mock instance

func (*MockdatabaseCleanupManager) Cleanup 

func (m *MockdatabaseCleanupManager) Cleanup(t time.Time) error

Cleanup mocks base method

func (*MockdatabaseCleanupManager) EXPECT 

func (m *MockdatabaseCleanupManager) EXPECT() *MockdatabaseCleanupManagerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockdatabaseCleanupManager) Report 

func (m *MockdatabaseCleanupManager) Report()

Report mocks base method

type MockdatabaseCleanupManagerMockRecorder 

type MockdatabaseCleanupManagerMockRecorder struct {
	// contains filtered or unexported fields
}

MockdatabaseCleanupManagerMockRecorder is the mock recorder for MockdatabaseCleanupManager

func (*MockdatabaseCleanupManagerMockRecorder) Cleanup 

func (mr *MockdatabaseCleanupManagerMockRecorder) Cleanup(t interface{}) *gomock.Call

Cleanup indicates an expected call of Cleanup

func (*MockdatabaseCleanupManagerMockRecorder) Report 

func (mr *MockdatabaseCleanupManagerMockRecorder) Report() *gomock.Call

Report indicates an expected call of Report

type MockdatabaseFileSystemManager 

type MockdatabaseFileSystemManager struct {
	// contains filtered or unexported fields
}

MockdatabaseFileSystemManager is a mock of databaseFileSystemManager interface

func NewMockdatabaseFileSystemManager 

func NewMockdatabaseFileSystemManager(ctrl *gomock.Controller) *MockdatabaseFileSystemManager

NewMockdatabaseFileSystemManager creates a new mock instance

func (*MockdatabaseFileSystemManager) Cleanup 

func (m *MockdatabaseFileSystemManager) Cleanup(t time.Time) error

Cleanup mocks base method

func (*MockdatabaseFileSystemManager) Disable 

func (m *MockdatabaseFileSystemManager) Disable() fileOpStatus

Disable mocks base method

func (*MockdatabaseFileSystemManager) EXPECT 

func (m *MockdatabaseFileSystemManager) EXPECT() *MockdatabaseFileSystemManagerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockdatabaseFileSystemManager) Enable 

func (m *MockdatabaseFileSystemManager) Enable() fileOpStatus

Enable mocks base method

func (*MockdatabaseFileSystemManager) Flush 

func (m *MockdatabaseFileSystemManager) Flush(t time.Time, dbBootstrapStateAtTickStart DatabaseBootstrapState) error

Flush mocks base method

func (*MockdatabaseFileSystemManager) Report 

func (m *MockdatabaseFileSystemManager) Report()

Report mocks base method

func (*MockdatabaseFileSystemManager) Run 

func (m *MockdatabaseFileSystemManager) Run(t time.Time, dbBootstrapStateAtTickStart DatabaseBootstrapState, runType runType, forceType forceType) bool

Run mocks base method

func (*MockdatabaseFileSystemManager) Status 

func (m *MockdatabaseFileSystemManager) Status() fileOpStatus

Status mocks base method

type MockdatabaseFileSystemManagerMockRecorder 

type MockdatabaseFileSystemManagerMockRecorder struct {
	// contains filtered or unexported fields
}

MockdatabaseFileSystemManagerMockRecorder is the mock recorder for MockdatabaseFileSystemManager

func (*MockdatabaseFileSystemManagerMockRecorder) Cleanup 

func (mr *MockdatabaseFileSystemManagerMockRecorder) Cleanup(t interface{}) *gomock.Call

Cleanup indicates an expected call of Cleanup

func (*MockdatabaseFileSystemManagerMockRecorder) Disable 

func (mr *MockdatabaseFileSystemManagerMockRecorder) Disable() *gomock.Call

Disable indicates an expected call of Disable

func (*MockdatabaseFileSystemManagerMockRecorder) Enable 

func (mr *MockdatabaseFileSystemManagerMockRecorder) Enable() *gomock.Call

Enable indicates an expected call of Enable

func (*MockdatabaseFileSystemManagerMockRecorder) Flush 

func (mr *MockdatabaseFileSystemManagerMockRecorder) Flush(t, dbBootstrapStateAtTickStart interface{}) *gomock.Call

Flush indicates an expected call of Flush

func (*MockdatabaseFileSystemManagerMockRecorder) Report 

func (mr *MockdatabaseFileSystemManagerMockRecorder) Report() *gomock.Call

Report indicates an expected call of Report

func (*MockdatabaseFileSystemManagerMockRecorder) Run 

func (mr *MockdatabaseFileSystemManagerMockRecorder) Run(t, dbBootstrapStateAtTickStart, runType, forceType interface{}) *gomock.Call

Run indicates an expected call of Run

func (*MockdatabaseFileSystemManagerMockRecorder) Status 

func (mr *MockdatabaseFileSystemManagerMockRecorder) Status() *gomock.Call

Status indicates an expected call of Status

type MockdatabaseFlushManager 

type MockdatabaseFlushManager struct {
	// contains filtered or unexported fields
}

MockdatabaseFlushManager is a mock of databaseFlushManager interface

func NewMockdatabaseFlushManager 

func NewMockdatabaseFlushManager(ctrl *gomock.Controller) *MockdatabaseFlushManager

NewMockdatabaseFlushManager creates a new mock instance

func (*MockdatabaseFlushManager) EXPECT 

func (m *MockdatabaseFlushManager) EXPECT() *MockdatabaseFlushManagerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockdatabaseFlushManager) Flush 

func (m *MockdatabaseFlushManager) Flush(tickStart time.Time, dbBootstrapStateAtTickStart DatabaseBootstrapState) error

Flush mocks base method

func (*MockdatabaseFlushManager) Report 

func (m *MockdatabaseFlushManager) Report()

Report mocks base method

type MockdatabaseFlushManagerMockRecorder 

type MockdatabaseFlushManagerMockRecorder struct {
	// contains filtered or unexported fields
}

MockdatabaseFlushManagerMockRecorder is the mock recorder for MockdatabaseFlushManager

func (*MockdatabaseFlushManagerMockRecorder) Flush 

func (mr *MockdatabaseFlushManagerMockRecorder) Flush(tickStart, dbBootstrapStateAtTickStart interface{}) *gomock.Call

Flush indicates an expected call of Flush

func (*MockdatabaseFlushManagerMockRecorder) Report 

func (mr *MockdatabaseFlushManagerMockRecorder) Report() *gomock.Call

Report indicates an expected call of Report

type MockdatabaseMediator 

type MockdatabaseMediator struct {
	// contains filtered or unexported fields
}

MockdatabaseMediator is a mock of databaseMediator interface

func NewMockdatabaseMediator 

func NewMockdatabaseMediator(ctrl *gomock.Controller) *MockdatabaseMediator

NewMockdatabaseMediator creates a new mock instance

func (*MockdatabaseMediator) Bootstrap 

func (m *MockdatabaseMediator) Bootstrap() error

Bootstrap mocks base method

func (*MockdatabaseMediator) Close 

func (m *MockdatabaseMediator) Close() error

Close mocks base method

func (*MockdatabaseMediator) DisableFileOps 

func (m *MockdatabaseMediator) DisableFileOps()

DisableFileOps mocks base method

func (*MockdatabaseMediator) EXPECT 

func (m *MockdatabaseMediator) EXPECT() *MockdatabaseMediatorMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockdatabaseMediator) EnableFileOps 

func (m *MockdatabaseMediator) EnableFileOps()

EnableFileOps mocks base method

func (*MockdatabaseMediator) IsBootstrapped 

func (m *MockdatabaseMediator) IsBootstrapped() bool

IsBootstrapped mocks base method

func (*MockdatabaseMediator) Open 

func (m *MockdatabaseMediator) Open() error

Open mocks base method

func (*MockdatabaseMediator) Repair 

func (m *MockdatabaseMediator) Repair() error

Repair mocks base method

func (*MockdatabaseMediator) Report 

func (m *MockdatabaseMediator) Report()

Report mocks base method

func (*MockdatabaseMediator) Tick 

func (m *MockdatabaseMediator) Tick(runType runType, forceType forceType) error

Tick mocks base method

type MockdatabaseMediatorMockRecorder 

type MockdatabaseMediatorMockRecorder struct {
	// contains filtered or unexported fields
}

MockdatabaseMediatorMockRecorder is the mock recorder for MockdatabaseMediator

func (*MockdatabaseMediatorMockRecorder) Bootstrap 

func (mr *MockdatabaseMediatorMockRecorder) Bootstrap() *gomock.Call

Bootstrap indicates an expected call of Bootstrap

func (*MockdatabaseMediatorMockRecorder) Close 

func (mr *MockdatabaseMediatorMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close

func (*MockdatabaseMediatorMockRecorder) DisableFileOps 

func (mr *MockdatabaseMediatorMockRecorder) DisableFileOps() *gomock.Call

DisableFileOps indicates an expected call of DisableFileOps

func (*MockdatabaseMediatorMockRecorder) EnableFileOps 

func (mr *MockdatabaseMediatorMockRecorder) EnableFileOps() *gomock.Call

EnableFileOps indicates an expected call of EnableFileOps

func (*MockdatabaseMediatorMockRecorder) IsBootstrapped 

func (mr *MockdatabaseMediatorMockRecorder) IsBootstrapped() *gomock.Call

IsBootstrapped indicates an expected call of IsBootstrapped

func (*MockdatabaseMediatorMockRecorder) Open 

func (mr *MockdatabaseMediatorMockRecorder) Open() *gomock.Call

Open indicates an expected call of Open

func (*MockdatabaseMediatorMockRecorder) Repair 

func (mr *MockdatabaseMediatorMockRecorder) Repair() *gomock.Call

Repair indicates an expected call of Repair

func (*MockdatabaseMediatorMockRecorder) Report 

func (mr *MockdatabaseMediatorMockRecorder) Report() *gomock.Call

Report indicates an expected call of Report

func (*MockdatabaseMediatorMockRecorder) Tick 

func (mr *MockdatabaseMediatorMockRecorder) Tick(runType, forceType interface{}) *gomock.Call

Tick indicates an expected call of Tick

type MockdatabaseMockRecorder 

type MockdatabaseMockRecorder struct {
	// contains filtered or unexported fields
}

MockdatabaseMockRecorder is the mock recorder for Mockdatabase

func (*MockdatabaseMockRecorder) AssignShardSet 

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

AssignShardSet indicates an expected call of AssignShardSet

func (*MockdatabaseMockRecorder) Bootstrap 

func (mr *MockdatabaseMockRecorder) Bootstrap() *gomock.Call

Bootstrap indicates an expected call of Bootstrap

func (*MockdatabaseMockRecorder) BootstrapState 

func (mr *MockdatabaseMockRecorder) BootstrapState() *gomock.Call

BootstrapState indicates an expected call of BootstrapState

func (*MockdatabaseMockRecorder) Close 

func (mr *MockdatabaseMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close

func (*MockdatabaseMockRecorder) FetchBlocks 

func (mr *MockdatabaseMockRecorder) FetchBlocks(ctx, namespace, shard, id, starts interface{}) *gomock.Call

FetchBlocks indicates an expected call of FetchBlocks

func (*MockdatabaseMockRecorder) FetchBlocksMetadata 

func (mr *MockdatabaseMockRecorder) FetchBlocksMetadata(ctx, namespace, shard, start, end, limit, pageToken, opts interface{}) *gomock.Call

FetchBlocksMetadata indicates an expected call of FetchBlocksMetadata

func (*MockdatabaseMockRecorder) FetchBlocksMetadataV2 

func (mr *MockdatabaseMockRecorder) FetchBlocksMetadataV2(ctx, namespace, shard, start, end, limit, pageToken, opts interface{}) *gomock.Call

FetchBlocksMetadataV2 indicates an expected call of FetchBlocksMetadataV2

func (*MockdatabaseMockRecorder) GetOwnedNamespaces 

func (mr *MockdatabaseMockRecorder) GetOwnedNamespaces() *gomock.Call

GetOwnedNamespaces indicates an expected call of GetOwnedNamespaces

func (*MockdatabaseMockRecorder) IsBootstrapped 

func (mr *MockdatabaseMockRecorder) IsBootstrapped() *gomock.Call

IsBootstrapped indicates an expected call of IsBootstrapped

func (*MockdatabaseMockRecorder) IsOverloaded 

func (mr *MockdatabaseMockRecorder) IsOverloaded() *gomock.Call

IsOverloaded indicates an expected call of IsOverloaded

func (*MockdatabaseMockRecorder) Namespace 

func (mr *MockdatabaseMockRecorder) Namespace(ns interface{}) *gomock.Call

Namespace indicates an expected call of Namespace

func (*MockdatabaseMockRecorder) Namespaces 

func (mr *MockdatabaseMockRecorder) Namespaces() *gomock.Call

Namespaces indicates an expected call of Namespaces

func (*MockdatabaseMockRecorder) Open 

func (mr *MockdatabaseMockRecorder) Open() *gomock.Call

Open indicates an expected call of Open

func (*MockdatabaseMockRecorder) Options 

func (mr *MockdatabaseMockRecorder) Options() *gomock.Call

Options indicates an expected call of Options

func (*MockdatabaseMockRecorder) QueryIDs 

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

QueryIDs indicates an expected call of QueryIDs

func (*MockdatabaseMockRecorder) ReadEncoded 

func (mr *MockdatabaseMockRecorder) ReadEncoded(ctx, namespace, id, start, end interface{}) *gomock.Call

ReadEncoded indicates an expected call of ReadEncoded

func (*MockdatabaseMockRecorder) Repair 

func (mr *MockdatabaseMockRecorder) Repair() *gomock.Call

Repair indicates an expected call of Repair

func (*MockdatabaseMockRecorder) ShardSet 

func (mr *MockdatabaseMockRecorder) ShardSet() *gomock.Call

ShardSet indicates an expected call of ShardSet

func (*MockdatabaseMockRecorder) Terminate 

func (mr *MockdatabaseMockRecorder) Terminate() *gomock.Call

Terminate indicates an expected call of Terminate

func (*MockdatabaseMockRecorder) Truncate 

func (mr *MockdatabaseMockRecorder) Truncate(namespace interface{}) *gomock.Call

Truncate indicates an expected call of Truncate

func (*MockdatabaseMockRecorder) UpdateOwnedNamespaces 

func (mr *MockdatabaseMockRecorder) UpdateOwnedNamespaces(namespaces interface{}) *gomock.Call

UpdateOwnedNamespaces indicates an expected call of UpdateOwnedNamespaces

func (*MockdatabaseMockRecorder) Write 

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

Write indicates an expected call of Write

func (*MockdatabaseMockRecorder) WriteTagged 

func (mr *MockdatabaseMockRecorder) WriteTagged(ctx, namespace, id, tags, timestamp, value, unit, annotation interface{}) *gomock.Call

WriteTagged indicates an expected call of WriteTagged

type MockdatabaseNamespace 

type MockdatabaseNamespace struct {
	// contains filtered or unexported fields
}

MockdatabaseNamespace is a mock of databaseNamespace interface

func NewMockdatabaseNamespace 

func NewMockdatabaseNamespace(ctrl *gomock.Controller) *MockdatabaseNamespace

NewMockdatabaseNamespace creates a new mock instance

func (*MockdatabaseNamespace) AssignShardSet 

func (m *MockdatabaseNamespace) AssignShardSet(shardSet sharding.ShardSet)

AssignShardSet mocks base method

func (*MockdatabaseNamespace) Bootstrap 

func (m *MockdatabaseNamespace) Bootstrap(start time.Time, process bootstrap.Process) error

Bootstrap mocks base method

func (*MockdatabaseNamespace) BootstrapState 

func (m *MockdatabaseNamespace) BootstrapState() ShardBootstrapStates

BootstrapState mocks base method

func (*MockdatabaseNamespace) Close 

func (m *MockdatabaseNamespace) Close() error

Close mocks base method

func (*MockdatabaseNamespace) EXPECT 

func (m *MockdatabaseNamespace) EXPECT() *MockdatabaseNamespaceMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockdatabaseNamespace) FetchBlocks 

func (m *MockdatabaseNamespace) FetchBlocks(ctx context.Context, shardID uint32, id ident.ID, starts []time.Time) ([]block.FetchBlockResult, error)

FetchBlocks mocks base method

func (*MockdatabaseNamespace) FetchBlocksMetadata 

func (m *MockdatabaseNamespace) FetchBlocksMetadata(ctx context.Context, shardID uint32, start, end time.Time, limit, pageToken int64, opts block.FetchBlocksMetadataOptions) (block.FetchBlocksMetadataResults, *int64, error)

FetchBlocksMetadata mocks base method

func (*MockdatabaseNamespace) FetchBlocksMetadataV2 

func (m *MockdatabaseNamespace) FetchBlocksMetadataV2(ctx context.Context, shardID uint32, start, end time.Time, limit int64, pageToken PageToken, opts block.FetchBlocksMetadataOptions) (block.FetchBlocksMetadataResults, PageToken, error)

FetchBlocksMetadataV2 mocks base method

func (*MockdatabaseNamespace) Flush 

func (m *MockdatabaseNamespace) Flush(blockStart time.Time, ShardBootstrapStates ShardBootstrapStates, flush persist.DataFlush) error

Flush mocks base method

func (*MockdatabaseNamespace) FlushIndex 

func (m *MockdatabaseNamespace) FlushIndex(flush persist.IndexFlush) error

FlushIndex mocks base method

func (*MockdatabaseNamespace) GetIndex 

func (m *MockdatabaseNamespace) GetIndex() (namespaceIndex, error)

GetIndex mocks base method

func (*MockdatabaseNamespace) GetOwnedShards 

func (m *MockdatabaseNamespace) GetOwnedShards() []databaseShard

GetOwnedShards mocks base method

func (*MockdatabaseNamespace) ID 

func (m *MockdatabaseNamespace) ID() ident.ID

ID mocks base method

func (*MockdatabaseNamespace) IsCapturedBySnapshot added in v0.4.0 

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

IsCapturedBySnapshot mocks base method

func (*MockdatabaseNamespace) NeedsFlush 

func (m *MockdatabaseNamespace) NeedsFlush(alignedInclusiveStart, alignedInclusiveEnd time.Time) bool

NeedsFlush mocks base method

func (*MockdatabaseNamespace) NumSeries 

func (m *MockdatabaseNamespace) NumSeries() int64

NumSeries mocks base method

func (*MockdatabaseNamespace) Options 

func (m *MockdatabaseNamespace) Options() namespace.Options

Options mocks base method

func (*MockdatabaseNamespace) QueryIDs 

func (m *MockdatabaseNamespace) QueryIDs(ctx context.Context, query index.Query, opts index.QueryOptions) (index.QueryResults, error)

QueryIDs mocks base method

func (*MockdatabaseNamespace) ReadEncoded 

func (m *MockdatabaseNamespace) ReadEncoded(ctx context.Context, id ident.ID, start, end time.Time) ([][]xio.BlockReader, error)

ReadEncoded mocks base method

func (*MockdatabaseNamespace) Repair 

func (m *MockdatabaseNamespace) Repair(repairer databaseShardRepairer, tr time0.Range) error

Repair mocks base method

func (*MockdatabaseNamespace) Shards 

func (m *MockdatabaseNamespace) Shards() []Shard

Shards mocks base method

func (*MockdatabaseNamespace) Snapshot 

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

Snapshot mocks base method

func (*MockdatabaseNamespace) Tick 

func (m *MockdatabaseNamespace) Tick(c context.Cancellable, tickStart time.Time) error

Tick mocks base method

func (*MockdatabaseNamespace) Truncate 

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

Truncate mocks base method

func (*MockdatabaseNamespace) Write 

func (m *MockdatabaseNamespace) Write(ctx context.Context, id ident.ID, timestamp time.Time, value float64, unit time0.Unit, annotation []byte) error

Write mocks base method

func (*MockdatabaseNamespace) WriteTagged 

func (m *MockdatabaseNamespace) WriteTagged(ctx context.Context, id ident.ID, tags ident.TagIterator, timestamp time.Time, value float64, unit time0.Unit, annotation []byte) error

WriteTagged mocks base method

type MockdatabaseNamespaceMockRecorder 

type MockdatabaseNamespaceMockRecorder struct {
	// contains filtered or unexported fields
}

MockdatabaseNamespaceMockRecorder is the mock recorder for MockdatabaseNamespace

func (*MockdatabaseNamespaceMockRecorder) AssignShardSet 

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

AssignShardSet indicates an expected call of AssignShardSet

func (*MockdatabaseNamespaceMockRecorder) Bootstrap 

func (mr *MockdatabaseNamespaceMockRecorder) Bootstrap(start, process interface{}) *gomock.Call

Bootstrap indicates an expected call of Bootstrap

func (*MockdatabaseNamespaceMockRecorder) BootstrapState 

func (mr *MockdatabaseNamespaceMockRecorder) BootstrapState() *gomock.Call

BootstrapState indicates an expected call of BootstrapState

func (*MockdatabaseNamespaceMockRecorder) Close 

func (mr *MockdatabaseNamespaceMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close

func (*MockdatabaseNamespaceMockRecorder) FetchBlocks 

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

FetchBlocks indicates an expected call of FetchBlocks

func (*MockdatabaseNamespaceMockRecorder) FetchBlocksMetadata 

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

FetchBlocksMetadata indicates an expected call of FetchBlocksMetadata

func (*MockdatabaseNamespaceMockRecorder) FetchBlocksMetadataV2 

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

FetchBlocksMetadataV2 indicates an expected call of FetchBlocksMetadataV2

func (*MockdatabaseNamespaceMockRecorder) Flush 

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

Flush indicates an expected call of Flush

func (*MockdatabaseNamespaceMockRecorder) FlushIndex 

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

FlushIndex indicates an expected call of FlushIndex

func (*MockdatabaseNamespaceMockRecorder) GetIndex 

func (mr *MockdatabaseNamespaceMockRecorder) GetIndex() *gomock.Call

GetIndex indicates an expected call of GetIndex

func (*MockdatabaseNamespaceMockRecorder) GetOwnedShards 

func (mr *MockdatabaseNamespaceMockRecorder) GetOwnedShards() *gomock.Call

GetOwnedShards indicates an expected call of GetOwnedShards

func (*MockdatabaseNamespaceMockRecorder) ID 

func (mr *MockdatabaseNamespaceMockRecorder) ID() *gomock.Call

ID indicates an expected call of ID

func (*MockdatabaseNamespaceMockRecorder) IsCapturedBySnapshot added in v0.4.0 

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

IsCapturedBySnapshot indicates an expected call of IsCapturedBySnapshot

func (*MockdatabaseNamespaceMockRecorder) NeedsFlush 

func (mr *MockdatabaseNamespaceMockRecorder) NeedsFlush(alignedInclusiveStart, alignedInclusiveEnd interface{}) *gomock.Call

NeedsFlush indicates an expected call of NeedsFlush

func (*MockdatabaseNamespaceMockRecorder) NumSeries 

func (mr *MockdatabaseNamespaceMockRecorder) NumSeries() *gomock.Call

NumSeries indicates an expected call of NumSeries

func (*MockdatabaseNamespaceMockRecorder) Options 

func (mr *MockdatabaseNamespaceMockRecorder) Options() *gomock.Call

Options indicates an expected call of Options

func (*MockdatabaseNamespaceMockRecorder) QueryIDs 

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

QueryIDs indicates an expected call of QueryIDs

func (*MockdatabaseNamespaceMockRecorder) ReadEncoded 

func (mr *MockdatabaseNamespaceMockRecorder) ReadEncoded(ctx, id, start, end interface{}) *gomock.Call

ReadEncoded indicates an expected call of ReadEncoded

func (*MockdatabaseNamespaceMockRecorder) Repair 

func (mr *MockdatabaseNamespaceMockRecorder) Repair(repairer, tr interface{}) *gomock.Call

Repair indicates an expected call of Repair

func (*MockdatabaseNamespaceMockRecorder) Shards 

func (mr *MockdatabaseNamespaceMockRecorder) Shards() *gomock.Call

Shards indicates an expected call of Shards

func (*MockdatabaseNamespaceMockRecorder) Snapshot 

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

Snapshot indicates an expected call of Snapshot

func (*MockdatabaseNamespaceMockRecorder) Tick 

func (mr *MockdatabaseNamespaceMockRecorder) Tick(c, tickStart interface{}) *gomock.Call

Tick indicates an expected call of Tick

func (*MockdatabaseNamespaceMockRecorder) Truncate 

func (mr *MockdatabaseNamespaceMockRecorder) Truncate() *gomock.Call

Truncate indicates an expected call of Truncate

func (*MockdatabaseNamespaceMockRecorder) Write 

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

Write indicates an expected call of Write

func (*MockdatabaseNamespaceMockRecorder) WriteTagged 

func (mr *MockdatabaseNamespaceMockRecorder) WriteTagged(ctx, id, tags, timestamp, value, unit, annotation interface{}) *gomock.Call

WriteTagged indicates an expected call of WriteTagged

type MockdatabaseNamespaceWatch 

type MockdatabaseNamespaceWatch struct {
	// contains filtered or unexported fields
}

MockdatabaseNamespaceWatch is a mock of databaseNamespaceWatch interface

func NewMockdatabaseNamespaceWatch 

func NewMockdatabaseNamespaceWatch(ctrl *gomock.Controller) *MockdatabaseNamespaceWatch

NewMockdatabaseNamespaceWatch creates a new mock instance

func (*MockdatabaseNamespaceWatch) Close 

func (m *MockdatabaseNamespaceWatch) Close() error

Close mocks base method

func (*MockdatabaseNamespaceWatch) EXPECT 

func (m *MockdatabaseNamespaceWatch) EXPECT() *MockdatabaseNamespaceWatchMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockdatabaseNamespaceWatch) Start 

func (m *MockdatabaseNamespaceWatch) Start() error

Start mocks base method

func (*MockdatabaseNamespaceWatch) Stop 

func (m *MockdatabaseNamespaceWatch) Stop() error

Stop mocks base method

type MockdatabaseNamespaceWatchMockRecorder 

type MockdatabaseNamespaceWatchMockRecorder struct {
	// contains filtered or unexported fields
}

MockdatabaseNamespaceWatchMockRecorder is the mock recorder for MockdatabaseNamespaceWatch

func (*MockdatabaseNamespaceWatchMockRecorder) Close 

func (mr *MockdatabaseNamespaceWatchMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close

func (*MockdatabaseNamespaceWatchMockRecorder) Start 

func (mr *MockdatabaseNamespaceWatchMockRecorder) Start() *gomock.Call

Start indicates an expected call of Start

func (*MockdatabaseNamespaceWatchMockRecorder) Stop 

func (mr *MockdatabaseNamespaceWatchMockRecorder) Stop() *gomock.Call

Stop indicates an expected call of Stop

type MockdatabaseRepairer 

type MockdatabaseRepairer struct {
	// contains filtered or unexported fields
}

MockdatabaseRepairer is a mock of databaseRepairer interface

func NewMockdatabaseRepairer 

func NewMockdatabaseRepairer(ctrl *gomock.Controller) *MockdatabaseRepairer

NewMockdatabaseRepairer creates a new mock instance

func (*MockdatabaseRepairer) EXPECT 

func (m *MockdatabaseRepairer) EXPECT() *MockdatabaseRepairerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockdatabaseRepairer) Repair 

func (m *MockdatabaseRepairer) Repair() error

Repair mocks base method

func (*MockdatabaseRepairer) Report 

func (m *MockdatabaseRepairer) Report()

Report mocks base method

func (*MockdatabaseRepairer) Start 

func (m *MockdatabaseRepairer) Start()

Start mocks base method

func (*MockdatabaseRepairer) Stop 

func (m *MockdatabaseRepairer) Stop()

Stop mocks base method

type MockdatabaseRepairerMockRecorder 

type MockdatabaseRepairerMockRecorder struct {
	// contains filtered or unexported fields
}

MockdatabaseRepairerMockRecorder is the mock recorder for MockdatabaseRepairer

func (*MockdatabaseRepairerMockRecorder) Repair 

func (mr *MockdatabaseRepairerMockRecorder) Repair() *gomock.Call

Repair indicates an expected call of Repair

func (*MockdatabaseRepairerMockRecorder) Report 

func (mr *MockdatabaseRepairerMockRecorder) Report() *gomock.Call

Report indicates an expected call of Report

func (*MockdatabaseRepairerMockRecorder) Start 

func (mr *MockdatabaseRepairerMockRecorder) Start() *gomock.Call

Start indicates an expected call of Start

func (*MockdatabaseRepairerMockRecorder) Stop 

func (mr *MockdatabaseRepairerMockRecorder) Stop() *gomock.Call

Stop indicates an expected call of Stop

type MockdatabaseShard 

type MockdatabaseShard struct {
	// contains filtered or unexported fields
}

MockdatabaseShard is a mock of databaseShard interface

func NewMockdatabaseShard 

func NewMockdatabaseShard(ctrl *gomock.Controller) *MockdatabaseShard

NewMockdatabaseShard creates a new mock instance

func (*MockdatabaseShard) Bootstrap 

func (m *MockdatabaseShard) Bootstrap(bootstrappedSeries *result.Map) error

Bootstrap mocks base method

func (*MockdatabaseShard) BootstrapState 

func (m *MockdatabaseShard) BootstrapState() BootstrapState

BootstrapState mocks base method

func (*MockdatabaseShard) CleanupExpiredFileSets 

func (m *MockdatabaseShard) CleanupExpiredFileSets(earliestToRetain time.Time) error

CleanupExpiredFileSets mocks base method

func (*MockdatabaseShard) CleanupSnapshots 

func (m *MockdatabaseShard) CleanupSnapshots(earliestToRetain time.Time) error

CleanupSnapshots mocks base method

func (*MockdatabaseShard) Close 

func (m *MockdatabaseShard) Close() error

Close mocks base method

func (*MockdatabaseShard) EXPECT 

func (m *MockdatabaseShard) EXPECT() *MockdatabaseShardMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockdatabaseShard) FetchBlocks 

func (m *MockdatabaseShard) FetchBlocks(ctx context.Context, id ident.ID, starts []time.Time) ([]block.FetchBlockResult, error)

FetchBlocks mocks base method

func (*MockdatabaseShard) FetchBlocksMetadata 

func (m *MockdatabaseShard) FetchBlocksMetadata(ctx context.Context, start, end time.Time, limit, pageToken int64, opts block.FetchBlocksMetadataOptions) (block.FetchBlocksMetadataResults, *int64, error)

FetchBlocksMetadata mocks base method

func (*MockdatabaseShard) FetchBlocksMetadataV2 

func (m *MockdatabaseShard) FetchBlocksMetadataV2(ctx context.Context, start, end time.Time, limit int64, pageToken PageToken, opts block.FetchBlocksMetadataOptions) (block.FetchBlocksMetadataResults, PageToken, error)

FetchBlocksMetadataV2 mocks base method

func (*MockdatabaseShard) Flush 

func (m *MockdatabaseShard) Flush(blockStart time.Time, flush persist.DataFlush) error

Flush mocks base method

func (*MockdatabaseShard) FlushState 

func (m *MockdatabaseShard) FlushState(blockStart time.Time) fileOpState

FlushState mocks base method

func (*MockdatabaseShard) ID 

func (m *MockdatabaseShard) ID() uint32

ID mocks base method

func (*MockdatabaseShard) IsBootstrapped 

func (m *MockdatabaseShard) IsBootstrapped() bool

IsBootstrapped mocks base method

func (*MockdatabaseShard) NumSeries 

func (m *MockdatabaseShard) NumSeries() int64

NumSeries mocks base method

func (*MockdatabaseShard) OnEvictedFromWiredList 

func (m *MockdatabaseShard) OnEvictedFromWiredList(id ident.ID, blockStart time.Time)

OnEvictedFromWiredList mocks base method

func (*MockdatabaseShard) ReadEncoded 

func (m *MockdatabaseShard) ReadEncoded(ctx context.Context, id ident.ID, start, end time.Time) ([][]xio.BlockReader, error)

ReadEncoded mocks base method

func (*MockdatabaseShard) Repair 

func (m *MockdatabaseShard) Repair(ctx context.Context, tr time0.Range, repairer databaseShardRepairer) (repair.MetadataComparisonResult, error)

Repair mocks base method

func (*MockdatabaseShard) Snapshot 

func (m *MockdatabaseShard) Snapshot(blockStart, snapshotStart time.Time, flush persist.DataFlush) error

Snapshot mocks base method

func (*MockdatabaseShard) SnapshotState 

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

SnapshotState mocks base method

func (*MockdatabaseShard) Tick 

func (m *MockdatabaseShard) Tick(c context.Cancellable, tickStart time.Time) (tickResult, error)

Tick mocks base method

func (*MockdatabaseShard) Write 

func (m *MockdatabaseShard) Write(ctx context.Context, id ident.ID, timestamp time.Time, value float64, unit time0.Unit, annotation []byte) error

Write mocks base method

func (*MockdatabaseShard) WriteTagged 

func (m *MockdatabaseShard) WriteTagged(ctx context.Context, id ident.ID, tags ident.TagIterator, timestamp time.Time, value float64, unit time0.Unit, annotation []byte) error

WriteTagged mocks base method

type MockdatabaseShardMockRecorder 

type MockdatabaseShardMockRecorder struct {
	// contains filtered or unexported fields
}

MockdatabaseShardMockRecorder is the mock recorder for MockdatabaseShard

func (*MockdatabaseShardMockRecorder) Bootstrap 

func (mr *MockdatabaseShardMockRecorder) Bootstrap(bootstrappedSeries interface{}) *gomock.Call

Bootstrap indicates an expected call of Bootstrap

func (*MockdatabaseShardMockRecorder) BootstrapState 

func (mr *MockdatabaseShardMockRecorder) BootstrapState() *gomock.Call

BootstrapState indicates an expected call of BootstrapState

func (*MockdatabaseShardMockRecorder) CleanupExpiredFileSets 

func (mr *MockdatabaseShardMockRecorder) CleanupExpiredFileSets(earliestToRetain interface{}) *gomock.Call

CleanupExpiredFileSets indicates an expected call of CleanupExpiredFileSets

func (*MockdatabaseShardMockRecorder) CleanupSnapshots 

func (mr *MockdatabaseShardMockRecorder) CleanupSnapshots(earliestToRetain interface{}) *gomock.Call

CleanupSnapshots indicates an expected call of CleanupSnapshots

func (*MockdatabaseShardMockRecorder) Close 

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

Close indicates an expected call of Close

func (*MockdatabaseShardMockRecorder) FetchBlocks 

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

FetchBlocks indicates an expected call of FetchBlocks

func (*MockdatabaseShardMockRecorder) FetchBlocksMetadata 

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

FetchBlocksMetadata indicates an expected call of FetchBlocksMetadata

func (*MockdatabaseShardMockRecorder) FetchBlocksMetadataV2 

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

FetchBlocksMetadataV2 indicates an expected call of FetchBlocksMetadataV2

func (*MockdatabaseShardMockRecorder) Flush 

func (mr *MockdatabaseShardMockRecorder) Flush(blockStart, flush interface{}) *gomock.Call

Flush indicates an expected call of Flush

func (*MockdatabaseShardMockRecorder) FlushState 

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

FlushState indicates an expected call of FlushState

func (*MockdatabaseShardMockRecorder) ID 

func (mr *MockdatabaseShardMockRecorder) ID() *gomock.Call

ID indicates an expected call of ID

func (*MockdatabaseShardMockRecorder) IsBootstrapped 

func (mr *MockdatabaseShardMockRecorder) IsBootstrapped() *gomock.Call

IsBootstrapped indicates an expected call of IsBootstrapped

func (*MockdatabaseShardMockRecorder) NumSeries 

func (mr *MockdatabaseShardMockRecorder) NumSeries() *gomock.Call

NumSeries indicates an expected call of NumSeries

func (*MockdatabaseShardMockRecorder) OnEvictedFromWiredList 

func (mr *MockdatabaseShardMockRecorder) OnEvictedFromWiredList(id, blockStart interface{}) *gomock.Call

OnEvictedFromWiredList indicates an expected call of OnEvictedFromWiredList

func (*MockdatabaseShardMockRecorder) ReadEncoded 

func (mr *MockdatabaseShardMockRecorder) ReadEncoded(ctx, id, start, end interface{}) *gomock.Call

ReadEncoded indicates an expected call of ReadEncoded

func (*MockdatabaseShardMockRecorder) Repair 

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

Repair indicates an expected call of Repair

func (*MockdatabaseShardMockRecorder) Snapshot 

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

Snapshot indicates an expected call of Snapshot

func (*MockdatabaseShardMockRecorder) SnapshotState 

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

SnapshotState indicates an expected call of SnapshotState

func (*MockdatabaseShardMockRecorder) Tick 

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

Tick indicates an expected call of Tick

func (*MockdatabaseShardMockRecorder) Write 

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

Write indicates an expected call of Write

func (*MockdatabaseShardMockRecorder) WriteTagged 

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

WriteTagged indicates an expected call of WriteTagged

type MockdatabaseShardRepairer 

type MockdatabaseShardRepairer struct {
	// contains filtered or unexported fields
}

MockdatabaseShardRepairer is a mock of databaseShardRepairer interface

func NewMockdatabaseShardRepairer 

func NewMockdatabaseShardRepairer(ctrl *gomock.Controller) *MockdatabaseShardRepairer

NewMockdatabaseShardRepairer creates a new mock instance

func (*MockdatabaseShardRepairer) EXPECT 

func (m *MockdatabaseShardRepairer) EXPECT() *MockdatabaseShardRepairerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockdatabaseShardRepairer) Options 

func (m *MockdatabaseShardRepairer) Options() repair.Options

Options mocks base method

func (*MockdatabaseShardRepairer) Repair 

func (m *MockdatabaseShardRepairer) Repair(ctx context.Context, namespace ident.ID, tr time0.Range, shard databaseShard) (repair.MetadataComparisonResult, error)

Repair mocks base method

type MockdatabaseShardRepairerMockRecorder 

type MockdatabaseShardRepairerMockRecorder struct {
	// contains filtered or unexported fields
}

MockdatabaseShardRepairerMockRecorder is the mock recorder for MockdatabaseShardRepairer

func (*MockdatabaseShardRepairerMockRecorder) Options 

func (mr *MockdatabaseShardRepairerMockRecorder) Options() *gomock.Call

Options indicates an expected call of Options

func (*MockdatabaseShardRepairerMockRecorder) Repair 

func (mr *MockdatabaseShardRepairerMockRecorder) Repair(ctx, namespace, tr, shard interface{}) *gomock.Call

Repair indicates an expected call of Repair

type MockdatabaseTickManager 

type MockdatabaseTickManager struct {
	// contains filtered or unexported fields
}

MockdatabaseTickManager is a mock of databaseTickManager interface

func NewMockdatabaseTickManager 

func NewMockdatabaseTickManager(ctrl *gomock.Controller) *MockdatabaseTickManager

NewMockdatabaseTickManager creates a new mock instance

func (*MockdatabaseTickManager) EXPECT 

func (m *MockdatabaseTickManager) EXPECT() *MockdatabaseTickManagerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockdatabaseTickManager) Tick 

func (m *MockdatabaseTickManager) Tick(forceType forceType, tickStart time.Time) error

Tick mocks base method

type MockdatabaseTickManagerMockRecorder 

type MockdatabaseTickManagerMockRecorder struct {
	// contains filtered or unexported fields
}

MockdatabaseTickManagerMockRecorder is the mock recorder for MockdatabaseTickManager

func (*MockdatabaseTickManagerMockRecorder) Tick 

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

Tick indicates an expected call of Tick

type MocknamespaceIndex 

type MocknamespaceIndex struct {
	// contains filtered or unexported fields
}

MocknamespaceIndex is a mock of namespaceIndex interface

func NewMocknamespaceIndex 

func NewMocknamespaceIndex(ctrl *gomock.Controller) *MocknamespaceIndex

NewMocknamespaceIndex creates a new mock instance

func (*MocknamespaceIndex) BlockStartForWriteTime 

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

BlockStartForWriteTime mocks base method

func (*MocknamespaceIndex) Bootstrap 

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

Bootstrap mocks base method

func (*MocknamespaceIndex) CleanupExpiredFileSets 

func (m *MocknamespaceIndex) CleanupExpiredFileSets(t time.Time) error

CleanupExpiredFileSets mocks base method

func (*MocknamespaceIndex) Close 

func (m *MocknamespaceIndex) Close() error

Close mocks base method

func (*MocknamespaceIndex) EXPECT 

func (m *MocknamespaceIndex) EXPECT() *MocknamespaceIndexMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MocknamespaceIndex) Flush 

func (m *MocknamespaceIndex) Flush(flush persist.IndexFlush, shards []databaseShard) error

Flush mocks base method

func (*MocknamespaceIndex) Query 

func (m *MocknamespaceIndex) Query(ctx context.Context, query index.Query, opts index.QueryOptions) (index.QueryResults, error)

Query mocks base method

func (*MocknamespaceIndex) Tick 

func (m *MocknamespaceIndex) Tick(c context.Cancellable, tickStart time.Time) (namespaceIndexTickResult, error)

Tick mocks base method

func (*MocknamespaceIndex) WriteBatch 

func (m *MocknamespaceIndex) WriteBatch(batch *index.WriteBatch) error

WriteBatch mocks base method

type MocknamespaceIndexInsertQueue 

type MocknamespaceIndexInsertQueue struct {
	// contains filtered or unexported fields
}

MocknamespaceIndexInsertQueue is a mock of namespaceIndexInsertQueue interface

func NewMocknamespaceIndexInsertQueue 

func NewMocknamespaceIndexInsertQueue(ctrl *gomock.Controller) *MocknamespaceIndexInsertQueue

NewMocknamespaceIndexInsertQueue creates a new mock instance

func (*MocknamespaceIndexInsertQueue) EXPECT 

func (m *MocknamespaceIndexInsertQueue) EXPECT() *MocknamespaceIndexInsertQueueMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MocknamespaceIndexInsertQueue) InsertBatch 

func (m *MocknamespaceIndexInsertQueue) InsertBatch(batch *index.WriteBatch) (*sync.WaitGroup, error)

InsertBatch mocks base method

func (*MocknamespaceIndexInsertQueue) Start 

func (m *MocknamespaceIndexInsertQueue) Start() error

Start mocks base method

func (*MocknamespaceIndexInsertQueue) Stop 

func (m *MocknamespaceIndexInsertQueue) Stop() error

Stop mocks base method

type MocknamespaceIndexInsertQueueMockRecorder 

type MocknamespaceIndexInsertQueueMockRecorder struct {
	// contains filtered or unexported fields
}

MocknamespaceIndexInsertQueueMockRecorder is the mock recorder for MocknamespaceIndexInsertQueue

func (*MocknamespaceIndexInsertQueueMockRecorder) InsertBatch 

func (mr *MocknamespaceIndexInsertQueueMockRecorder) InsertBatch(batch interface{}) *gomock.Call

InsertBatch indicates an expected call of InsertBatch

func (*MocknamespaceIndexInsertQueueMockRecorder) Start 

func (mr *MocknamespaceIndexInsertQueueMockRecorder) Start() *gomock.Call

Start indicates an expected call of Start

func (*MocknamespaceIndexInsertQueueMockRecorder) Stop 

func (mr *MocknamespaceIndexInsertQueueMockRecorder) Stop() *gomock.Call

Stop indicates an expected call of Stop

type MocknamespaceIndexMockRecorder 

type MocknamespaceIndexMockRecorder struct {
	// contains filtered or unexported fields
}

MocknamespaceIndexMockRecorder is the mock recorder for MocknamespaceIndex

func (*MocknamespaceIndexMockRecorder) BlockStartForWriteTime 

func (mr *MocknamespaceIndexMockRecorder) BlockStartForWriteTime(writeTime interface{}) *gomock.Call

BlockStartForWriteTime indicates an expected call of BlockStartForWriteTime

func (*MocknamespaceIndexMockRecorder) Bootstrap 

func (mr *MocknamespaceIndexMockRecorder) Bootstrap(bootstrapResults interface{}) *gomock.Call

Bootstrap indicates an expected call of Bootstrap

func (*MocknamespaceIndexMockRecorder) CleanupExpiredFileSets 

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

CleanupExpiredFileSets indicates an expected call of CleanupExpiredFileSets

func (*MocknamespaceIndexMockRecorder) Close 

func (mr *MocknamespaceIndexMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close

func (*MocknamespaceIndexMockRecorder) Flush 

func (mr *MocknamespaceIndexMockRecorder) Flush(flush, shards interface{}) *gomock.Call

Flush indicates an expected call of Flush

func (*MocknamespaceIndexMockRecorder) Query 

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

Query indicates an expected call of Query

func (*MocknamespaceIndexMockRecorder) Tick 

func (mr *MocknamespaceIndexMockRecorder) Tick(c, tickStart interface{}) *gomock.Call

Tick indicates an expected call of Tick

func (*MocknamespaceIndexMockRecorder) WriteBatch 

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

WriteBatch indicates an expected call of WriteBatch

type Namespace 

type Namespace interface {
	// Options returns the namespace options
	Options() namespace.Options

	// ID returns the ID of the namespace
	ID() ident.ID

	// NumSeries returns the number of series in the namespace
	NumSeries() int64

	// Shards returns the shard description
	Shards() []Shard
}

Namespace is a time series database namespace

type NamespaceBootstrapStates 

type NamespaceBootstrapStates map[string]ShardBootstrapStates

NamespaceBootstrapStates stores a snapshot of the bootstrap state for all shards across a number of namespaces at a given moment in time.

type NamespacesByID 

type NamespacesByID []Namespace

NamespacesByID is a sortable slice of namespaces by ID

func (NamespacesByID) Len 

func (n NamespacesByID) Len() int

func (NamespacesByID) Less 

func (n NamespacesByID) Less(i, j int) bool

func (NamespacesByID) Swap 

func (n NamespacesByID) Swap(i, j int)

type Options 

type Options interface {
	// Validate validates assumptions baked into the code.
	Validate() error

	// SetEncodingM3TSZPooled sets m3tsz encoding with pooling.
	SetEncodingM3TSZPooled() Options

	// SetClockOptions sets the clock options.
	SetClockOptions(value clock.Options) Options

	// ClockOptions returns the clock options.
	ClockOptions() clock.Options

	// SetInstrumentOptions sets the instrumentation options.
	SetInstrumentOptions(value instrument.Options) Options

	// InstrumentOptions returns the instrumentation options.
	InstrumentOptions() instrument.Options

	// SetNamespaceInitializer sets the namespace registry initializer.
	SetNamespaceInitializer(value namespace.Initializer) Options

	// NamespaceInitializer returns the namespace registry initializer.
	NamespaceInitializer() namespace.Initializer

	// SetDatabaseBlockOptions sets the database block options.
	SetDatabaseBlockOptions(value block.Options) Options

	// DatabaseBlockOptions returns the database block options.
	DatabaseBlockOptions() block.Options

	// SetCommitLogOptions sets the commit log options.
	SetCommitLogOptions(value commitlog.Options) Options

	// CommitLogOptions returns the commit log options.
	CommitLogOptions() commitlog.Options

	// SetRuntimeOptionsManager sets the runtime options manager.
	SetRuntimeOptionsManager(value runtime.OptionsManager) Options

	// RuntimeOptionsManager returns the runtime options manager.
	RuntimeOptionsManager() runtime.OptionsManager

	// SetErrorCounterOptions sets the error counter options.
	SetErrorCounterOptions(value xcounter.Options) Options

	// ErrorCounterOptions returns the error counter options.
	ErrorCounterOptions() xcounter.Options

	// SetErrorWindowForLoad sets the error window for load.
	SetErrorWindowForLoad(value time.Duration) Options

	// ErrorWindowForLoad returns the error window for load.
	ErrorWindowForLoad() time.Duration

	// SetErrorThresholdForLoad sets the error threshold for load.
	SetErrorThresholdForLoad(value int64) Options

	// ErrorThresholdForLoad returns the error threshold for load.
	ErrorThresholdForLoad() int64

	// SetIndexOptions set the indexing options.
	SetIndexOptions(value index.Options) Options

	// IndexOptions returns the indexing options.
	IndexOptions() index.Options

	// SetRepairEnabled sets whether or not to enable the repair.
	SetRepairEnabled(b bool) Options

	// RepairEnabled returns whether the repair is enabled.
	RepairEnabled() bool

	// SetRepairOptions sets the repair options.
	SetRepairOptions(value repair.Options) Options

	// RepairOptions returns the repair options.
	RepairOptions() repair.Options

	// SetBootstrapProcessProvider sets the bootstrap process provider for the database.
	SetBootstrapProcessProvider(value bootstrap.ProcessProvider) Options

	// BootstrapProcessProvider returns the bootstrap process provider for the database.
	BootstrapProcessProvider() bootstrap.ProcessProvider

	// SetPersistManager sets the persistence manager.
	SetPersistManager(value persist.Manager) Options

	// PersistManager returns the persistence manager.
	PersistManager() persist.Manager

	// SetMinimumSnapshotInterval sets the minimum amount of time that must elapse between snapshots.
	SetMinimumSnapshotInterval(value time.Duration) Options

	// MinimumSnapshotInterval returns the minimum amount of time that must elapse between snapshots.
	MinimumSnapshotInterval() time.Duration

	// SetDatabaseBlockRetrieverManager sets the block retriever manager to
	// use when bootstrapping retrievable blocks instead of blocks
	// containing data.
	// If you don't wish to bootstrap retrievable blocks instead of
	// blocks containing data then do not set this manager.
	// You can opt into which namespace you wish to have this enabled for
	// by returning nil instead of a result when creating a new block retriever
	// for a namespace from the manager.
	SetDatabaseBlockRetrieverManager(
		value block.DatabaseBlockRetrieverManager,
	) Options

	// NewBlockRetrieverFn returns the new block retriever constructor to
	// use when bootstrapping retrievable blocks instead of blocks
	// containing data.
	DatabaseBlockRetrieverManager() block.DatabaseBlockRetrieverManager

	// SetContextPool sets the contextPool.
	SetContextPool(value context.Pool) Options

	// ContextPool returns the contextPool.
	ContextPool() context.Pool

	// SetSeriesCachePolicy sets the series cache policy.
	SetSeriesCachePolicy(value series.CachePolicy) Options

	// SeriesCachePolicy returns the series cache policy.
	SeriesCachePolicy() series.CachePolicy

	// SetSeriesOptions sets the series options.
	SetSeriesOptions(value series.Options) Options

	// SeriesOptions returns the series options.
	SeriesOptions() series.Options

	// SetDatabaseSeriesPool sets the database series pool.
	SetDatabaseSeriesPool(value series.DatabaseSeriesPool) Options

	// DatabaseSeriesPool returns the database series pool.
	DatabaseSeriesPool() series.DatabaseSeriesPool

	// SetBytesPool sets the bytesPool.
	SetBytesPool(value pool.CheckedBytesPool) Options

	// BytesPool returns the bytesPool.
	BytesPool() pool.CheckedBytesPool

	// SetEncoderPool sets the contextPool.
	SetEncoderPool(value encoding.EncoderPool) Options

	// EncoderPool returns the contextPool.
	EncoderPool() encoding.EncoderPool

	// SetSegmentReaderPool sets the contextPool.
	SetSegmentReaderPool(value xio.SegmentReaderPool) Options

	// SegmentReaderPool returns the contextPool.
	SegmentReaderPool() xio.SegmentReaderPool

	// SetReaderIteratorPool sets the readerIteratorPool.
	SetReaderIteratorPool(value encoding.ReaderIteratorPool) Options

	// ReaderIteratorPool returns the readerIteratorPool.
	ReaderIteratorPool() encoding.ReaderIteratorPool

	// SetMultiReaderIteratorPool sets the multiReaderIteratorPool.
	SetMultiReaderIteratorPool(value encoding.MultiReaderIteratorPool) Options

	// MultiReaderIteratorPool returns the multiReaderIteratorPool.
	MultiReaderIteratorPool() encoding.MultiReaderIteratorPool

	// SetIDPool sets the ID pool.
	SetIdentifierPool(value ident.Pool) Options

	// IDPool returns the ID pool.
	IdentifierPool() ident.Pool

	// SetFetchBlockMetadataResultsPool sets the fetchBlockMetadataResultsPool.
	SetFetchBlockMetadataResultsPool(value block.FetchBlockMetadataResultsPool) Options

	// FetchBlockMetadataResultsPool returns the fetchBlockMetadataResultsPool.
	FetchBlockMetadataResultsPool() block.FetchBlockMetadataResultsPool

	// SetFetchBlocksMetadataResultsPool sets the fetchBlocksMetadataResultsPool.
	SetFetchBlocksMetadataResultsPool(value block.FetchBlocksMetadataResultsPool) Options

	// FetchBlocksMetadataResultsPool returns the fetchBlocksMetadataResultsPool.
	FetchBlocksMetadataResultsPool() block.FetchBlocksMetadataResultsPool

	// SetQueryIDsWorkerPool sets the QueryIDs worker pool.
	SetQueryIDsWorkerPool(value xsync.WorkerPool) Options

	// QueryIDsWorkerPool returns the QueryIDs worker pool.
	QueryIDsWorkerPool() xsync.WorkerPool
}

Options represents the options for storage

func NewOptions 

func NewOptions() Options

NewOptions creates a new set of storage options with defaults

type PageToken 

type PageToken []byte

PageToken is an opaque paging token.

type Shard 

type Shard interface {
	// ID returns the ID of the shard
	ID() uint32

	// NumSeries returns the number of series in the shard
	NumSeries() int64

	// IsBootstrapped returns whether the shard is already bootstrapped
	IsBootstrapped() bool

	// BootstrapState returns the shards' bootstrap state.
	BootstrapState() BootstrapState
}

Shard is a time series database shard

type ShardBootstrapStates 

type ShardBootstrapStates map[uint32]BootstrapState

ShardBootstrapStates stores a snapshot of the bootstrap state for all shards for a given namespace.

Source Files

View all Source files

Directories

Path Synopsis
Package block is a generated GoMock package.
 Package block is a generated GoMock package.
Package bootstrap is a generated GoMock package.
 Package bootstrap is a generated GoMock package.
bootstrapper
bootstrapper/commitlog
bootstrapper/fs
bootstrapper/peers
result
Package index is a generated GoMock package.
 Package index is a generated GoMock package.
compaction
convert
segments
Package namespace is a generated GoMock package.
 Package namespace is a generated GoMock package.
Package series is a generated GoMock package.
 Package series is a generated GoMock package.
lookup

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.