Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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
// QueryStatsTrackerFn returns a tracker for tracking query stats.
QueryStatsTrackerFn func(instrument.Options) stats.QueryStatsTracker
// CustomOptions are custom options to apply to the session.
CustomOptions []client.CustomAdminOption
// StorageOptions are options to apply to the database storage options.
StorageOptions StorageOptions
}
RunOptions provides options for running the server with backwards compatibility if only solely adding fields.
type StorageOptions ¶ added in v0.15.0
type StorageOptions struct {
OnColdFlush storage.OnColdFlush
ForceColdWritesEnabled bool
TChanNodeServerFn node.NewTChanNodeServerFn
}
StorageOptions are options to apply to the database storage options.
Click to show internal directories.
Click to hide internal directories.