cmd

package
Version: v0.1.11 Latest Latest
Warning

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

Go to latest
Published: May 27, 2020 License: AGPL-3.0-only Imports: 24 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func BootstrapCluster

func BootstrapCluster(c *ClusterNodeConfig, s *store.Store, peerAddrs []string) error

func CanBootstrapCluster

func CanBootstrapCluster(c *ClusterNodeConfig, peerAddrs []string) (bool, error)

func CmdClusterClient

func CmdClusterClient(argv []string, version string)

func CmdClusterNode

func CmdClusterNode(argv []string, version string)

func InitializeMetrics

func InitializeMetrics(serviceName, metricsAddr string) error

func JoinCluster

func JoinCluster(c *ClusterNodeConfig, peerAddrs []string) error

func LeaveCluster

func LeaveCluster(c *ClusterNodeConfig, peerAddrs []string) error

func RunCoolbeans

func RunCoolbeans(c *ClusterNodeConfig) error

Types

type ClusterNodeConfig

type ClusterNodeConfig struct {
	NodeId          string
	NodeListenAddr  string
	RootDir         string
	NodePeerAddrs   string
	BootstrapNodeId string
	PeerTimeoutSecs int

	MaxClusterJoinAttempts       int
	ClusterJoinRetryIntervalSecs int

	RaftListenAddr       string
	RaftAdvertizedAddr   string
	RaftTimeoutSecs      int
	MaxPoolSize          int
	NoDiskLog            bool
	NoFsync              bool
	RestoreTimeoutSecs   int
	RetainSnapshotCount  int
	SnapshotThreshold    int
	TrailingLogCount     int
	SnapshotIntervalSecs int
	PrometheusAddr       string
}

Jump to

Keyboard shortcuts

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