cmd

Documentation

Index

• func BootstrapCluster(c *ClusterNodeConfig, s *store.Store, peerAddrs []string) error
• func CanBootstrapCluster(c *ClusterNodeConfig, peerAddrs []string) (bool, error)
• func CmdClusterClient(argv []string, version string)
• func CmdClusterNode(argv []string, version string)
• func InitializeMetrics(serviceName, metricsAddr string) error
• func JoinCluster(c *ClusterNodeConfig, peerAddrs []string) error
• func LeaveCluster(c *ClusterNodeConfig, peerAddrs []string) error
• func RunCoolbeans(c *ClusterNodeConfig) error
• type ClusterNodeConfig

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
}