Documentation
¶
Index ¶
Constants ¶
View Source
const (
// PeersBootstrapperName is the name of the peers bootstrapper
PeersBootstrapperName = "peers"
)
Variables ¶
View Source
var ( // DefaultShardConcurrency controls how many shards in parallel to stream // for in memory data being streamed between peers (most recent block). // Update BootstrapPeersConfiguration comment in // src/cmd/services/m3dbnode/config package if this is changed. DefaultShardConcurrency = runtime.NumCPU() // DefaultShardPersistenceConcurrency controls how many shards in parallel to stream // for historical data being streamed between peers (historical blocks). // Update BootstrapPeersConfiguration comment in // src/cmd/services/m3dbnode/config package if this is changed. DefaultShardPersistenceConcurrency = int(math.Max(1, float64(runtime.NumCPU())/2)) )
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
// SetCompactor sets the compactor used to compact segment builders into segments.
SetCompactor(value *compaction.Compactor) Options
// Compactor returns the compactor used to compact segment builders into segments.
Compactor() *compaction.Compactor
// SetRuntimeOptionsManagers sets the RuntimeOptionsManager.
SetRuntimeOptionsManager(value m3dbruntime.OptionsManager) Options
// RuntimeOptionsManagers returns the RuntimeOptionsManager.
RuntimeOptionsManager() m3dbruntime.OptionsManager
// SetContextPool sets the contextPool.
SetContextPool(value context.Pool) Options
// ContextPool returns the contextPool.
ContextPool() context.Pool
// SetFilesystemOptions sets the filesystem options.
SetFilesystemOptions(value fs.Options) Options
// FilesystemOptions returns the filesystem options.
FilesystemOptions() fs.Options
// SetIndexOptions set the indexing options.
SetIndexOptions(value index.Options) Options
// IndexOptions returns the indexing options.
IndexOptions() index.Options
}
Options represents the options for bootstrapping from peers
Click to show internal directories.
Click to hide internal directories.