run

Documentation

Index

• Constants
• func FollowerRoutine(ctx context.Context, logger logging.Logger, done chan<- bool)
• func LeaderRoutine(ctx context.Context, logger logging.Logger, done chan<- bool)
• type Run
  • func (cmd *Run) Execute(args []string) error

Constants

const LoopInterval time.Duration = 2 * time.Second

Functions

func FollowerRoutine

func FollowerRoutine(ctx context.Context, logger logging.Logger, done chan<- bool)

func LeaderRoutine

func LeaderRoutine(ctx context.Context, logger logging.Logger, done chan<- bool)

Types

type Run

type Run struct {
	base.Base
	// Bootstrap starts the cluster in bootstrap mode.
	Bootstrap bool `short:"b" long:"bootstrap" description:"Whether to boostrap the cluster." optional:"yes"`
	// Address is the intra-cluster bind address for Raft communications.
	Address cluster.Address `` /* 129-byte string literal not displayed */
	// Join specified whether the node should join a cluster.
	Peers []cluster.Peer `short:"p" long:"peer" description:"The address of a peer node in the cluster to join" optional:"yes"`
	// State is the directory for Raft cluster state storage.
	Directory string `` /* 143-byte string literal not displayed */
}

func (*Run) Execute

func (cmd *Run) Execute(args []string) error