Documentation
¶
Index ¶
Constants ¶
View Source
const (
// PeersBootstrapperName is the name of the peers bootstrapper
PeersBootstrapperName = "peers"
)
Variables ¶
This section is empty.
Functions ¶
func NewPeersBootstrapperProvider ¶
func NewPeersBootstrapperProvider( opts Options, next bootstrap.BootstrapperProvider, ) (bootstrap.BootstrapperProvider, error)
NewPeersBootstrapperProvider creates a new bootstrapper provider to bootstrap from peers.
Types ¶
type Options ¶
type Options interface {
// Validate validates the options
Validate() error
// SetResultOptions sets the instrumentation options
SetResultOptions(value result.Options) Options
// ResultOptions returns the instrumentation options
ResultOptions() result.Options
// SetAdminClient sets the admin client
SetAdminClient(value client.AdminClient) Options
// AdminClient returns the admin client
AdminClient() client.AdminClient
// SetDefaultShardConcurrency sets the concurrency for
// bootstrapping shards when performing a bootstrap with
// persistence enabled.
SetDefaultShardConcurrency(value int) Options
// DefaultShardConcurrency returns the concurrency for
// bootstrapping shards when performing a bootstrap with
// persistence enabled.
DefaultShardConcurrency() int
// SetShardPersistenceConcurrency sets the concurrency for
// bootstrapping shards when performing a bootstrap with
// persistence enabled.
SetShardPersistenceConcurrency(value int) Options
// ShardPersistenceConcurrency returns the concurrency for
// bootstrapping shards when performing a bootstrap with
// persistence enabled.
ShardPersistenceConcurrency() int
// SetPersistenceMaxQueueSize sets the max queue for
// bootstrapping shards waiting in line to persist without blocking
// the concurrent shard fetchers.
SetPersistenceMaxQueueSize(value int) Options
// PersistenceMaxQueueSize returns the max queue for
// bootstrapping shards waiting in line to persist without blocking
// the concurrent shard fetchers.
PersistenceMaxQueueSize() int
// SetPersistManager sets the persistence manager used to flush blocks
// when performing a bootstrap with persistence.
SetPersistManager(value persist.Manager) Options
// PersistManager returns the persistence manager used to flush blocks
// when performing a bootstrap with persistence.
PersistManager() persist.Manager
// SetDatabaseBlockRetrieverManager sets the block retriever manager to
// pass to newly flushed blocks when performing a bootstrap run with
// persistence enabled.
SetDatabaseBlockRetrieverManager(
value block.DatabaseBlockRetrieverManager,
) Options
// NewBlockRetrieverFn returns the block retriever manager to
// pass to newly flushed blocks when performing a bootstrap run with
// persistence enabled.
DatabaseBlockRetrieverManager() block.DatabaseBlockRetrieverManager
// SetRuntimeOptionsManagers sets the RuntimeOptionsManager.
SetRuntimeOptionsManager(value m3dbruntime.OptionsManager) Options
// RuntimeOptionsManagers returns the RuntimeOptionsManager.
RuntimeOptionsManager() m3dbruntime.OptionsManager
}
Options represents the options for bootstrapping from peers
Click to show internal directories.
Click to hide internal directories.