server

Documentation

Overview

Package server contains the code to run the dbnode server.

Index

• func Run(runOpts RunOptions)
• type RunOptions
• type StorageOptions

Functions

func Run

func Run(runOpts RunOptions)

Run runs the server programmatically given a filename for the configuration file.

Types

type RunOptions

type RunOptions struct {
	// ConfigFile is the YAML configuration file to use to run the server.
	ConfigFile string

	// Config is an alternate way to provide configuration and will be used
	// instead of parsing ConfigFile if ConfigFile is not specified.
	Config config.DBConfiguration

	// BootstrapCh is a channel to listen on to be notified of bootstrap.
	BootstrapCh chan<- struct{}

	// EmbeddedKVCh is a channel to listen on to be notified that the embedded KV has bootstrapped.
	EmbeddedKVCh chan<- struct{}

	// ClientCh is a channel to listen on to share the same m3db client that this server uses.
	ClientCh chan<- client.Client

	// ClusterClientCh is a channel to listen on to share the same m3 cluster client that this server uses.
	ClusterClientCh chan<- clusterclient.Client

	// InterruptCh is a programmatic interrupt channel to supply to
	// interrupt and shutdown the server.
	InterruptCh <-chan error

	// CustomOptions are custom options to apply to the session.
	CustomOptions []client.CustomAdminOption

	// StorageOptions are options to apply to the database storage options.
	StorageOptions StorageOptions

	// CustomBuildTags are additional tags to be added to the instrument build
	// reporter.
	CustomBuildTags map[string]string
}

RunOptions provides options for running the server with backwards compatibility if only solely adding fields.

type StorageOptions

type StorageOptions struct {
	OnColdFlush            storage.OnColdFlush
	ForceColdWritesEnabled bool
	TChanNodeServerFn      node.NewTChanNodeServerFn
	BackgroundProcessFns   []storage.NewBackgroundProcessFn
	NamespaceHooks         storage.NamespaceHooks
}

StorageOptions are options to apply to the database storage options.