commitlog

Documentation

Index

• Constants
• func NewCommitLogBootstrapperProvider(opts Options, inspection fs.Inspection, next bootstrap.BootstrapperProvider) (bootstrap.BootstrapperProvider, error)
• type Options
  • func NewOptions() Options

Constants

const (
	// CommitLogBootstrapperName is the name of the commit log bootstrapper.
	CommitLogBootstrapperName = "commitlog"
)

Functions

func NewCommitLogBootstrapperProvider

func NewCommitLogBootstrapperProvider(
	opts Options,
	inspection fs.Inspection,
	next bootstrap.BootstrapperProvider,
) (bootstrap.BootstrapperProvider, error)

NewCommitLogBootstrapperProvider creates a new bootstrapper provider to bootstrap from commit log files.

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

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

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

	// SetEncodingConcurrency sets the concurrency for encoding
	SetEncodingConcurrency(value int) Options

	// EncodingConcurrency returns the concurrency for encoding
	EncodingConcurrency() int

	// SetMergeShardConcurrency sets the concurrency for merging shards
	SetMergeShardsConcurrency(value int) Options

	// MergeShardConcurrency returns the concurrency for merging shards
	MergeShardsConcurrency() int
}

Options represents the options for bootstrapping from commit logs

func NewOptions

func NewOptions() Options

NewOptions creates new bootstrap options