datanode

package
v0.0.2 Latest Latest
Warning

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

Go to latest
Published: Sep 5, 2019 License: Apache-2.0 Imports: 37 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewPeerSource

func NewPeerSource(topo topology.Topology, dialerOverride client.PeerConnDialer) (client.PeerSource, error)

NewPeerSource creates PeerSource

Types

type BootstrapManager

type BootstrapManager interface {
	// IsBootstrapped returns whether the datanode is already bootstrapped.
	IsBootstrapped() bool

	// LastBootstrapCompletionTime returns the last bootstrap completion time,
	// if any.
	LastBootstrapCompletionTime() (time.Time, bool)

	// Bootstrap performs bootstrapping for all namespaces and shards owned.
	Bootstrap() error
}

BootstrapManager manages the bootstrap process.

func NewBootstrapManager

func NewBootstrapManager(origin string,
	bootstrappable bootstrap.Bootstrapable,
	bootstrapOpts bootstrap.Options,
	topo topology.Topology,
) BootstrapManager

NewBootstrapManager creates bootstrap manager

type DataNode

type DataNode interface {
	// Options returns the database options.
	Options() Options

	// ID returns the host id of the DataNode
	ID() string

	// ShardSet returns the set of shards currently associated with this datanode.
	ShardSet() shard.ShardSet

	// Open data node
	Open() error

	// Close data node
	Close()

	// serve will start serving read and write requests
	Serve()
}

func NewDataNode

func NewDataNode(
	hostID string,
	topo topology.Topology,
	enumReader mutatorsCom.EnumReader,
	opts Options) (DataNode, error)

NewDataNode creates a new data node

type Options

type Options interface {
	// SetInstrumentOptions sets the instrumentation options.
	SetInstrumentOptions(utils.Options) Options

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

	// Options returns bootstrap options
	BootstrapOptions() bootstrap.Options

	// SetBootstrapOptions sets bootstrap options
	SetBootstrapOptions(bootstrap.Options) Options

	// SetServerConfig sets server config
	SetServerConfig(common.AresServerConfig) Options

	// SetServerConfig returns server config
	ServerConfig() common.AresServerConfig

	// HTTPWrappers returns http handler wrappers
	HTTPWrappers() []utils.HTTPHandlerWrapper

	// SetHTTPWrappers returns http handler wrappers
	SetHTTPWrappers([]utils.HTTPHandlerWrapper) Options
}

Options represents the options for storage.

func NewOptions

func NewOptions() Options

NewOptions creates a new set of storage options with defaults

Directories

Path Synopsis
mocks
Code generated by mockery v1.0.0 Code generated by mockery v1.0.0
Code generated by mockery v1.0.0 Code generated by mockery v1.0.0
generated

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL