consensus

Documentation

Index

• type Consensus
  • func New(nodeID, raftPort, raftAdvertise, dataDir string, fsm raft.FSM) (*Consensus, error)
  • func (c *Consensus) Raft() *raft.Raft
  • func (c *Consensus) Shutdown() error
  • func (c *Consensus) WaitForLeader(timeout time.Duration) error

Types

type Consensus

type Consensus struct {
	// contains filtered or unexported fields
}

func New

func New(nodeID, raftPort, raftAdvertise, dataDir string, fsm raft.FSM) (*Consensus, error)

func (*Consensus) Raft

func (c *Consensus) Raft() *raft.Raft

func (*Consensus) Shutdown

func (c *Consensus) Shutdown() error

func (*Consensus) WaitForLeader

func (c *Consensus) WaitForLeader(timeout time.Duration) error