raft

func (*FSMSnapshot) Persist ¶

func (f *FSMSnapshot) Persist(sink raft.SnapshotSink) error

func (*FSMSnapshot) Release ¶

func (f *FSMSnapshot) Release()

func (*Raft) AddPeer ¶

func (b *Raft) AddPeer(addr string) error

AddPeer of given address to raft

func (*Raft) Addr ¶

func (b *Raft) Addr() string

Addr of raft node

func (*Raft) Apply ¶

func (b *Raft) Apply(cmd jocko.RaftCommand) error

Apply command to all raft nodes

func (*Raft) Bootstrap ¶

func (b *Raft) Bootstrap(peers []*jocko.ClusterMember, commandCh chan<- jocko.RaftCommand, leaderCh chan<- bool) (err error)

Bootstrap the Raft agent using fsm and connect to peers Updates to leadership are returned on leaderCh channel Commands received by raft are returned on commandCh channel

func (*Raft) IsLeader ¶

func (b *Raft) IsLeader() bool

IsLeader checks if this broker is the cluster controller

func (*Raft) LeaderID ¶

func (b *Raft) LeaderID() string

LeaderID is ID of the controller node

func (*Raft) RemovePeer ¶

func (b *Raft) RemovePeer(addr string) error

RemovePeer of given address from raft

func (*Raft) Shutdown ¶

func (b *Raft) Shutdown() error

Shutdown raft agent

func (*Raft) WaitForBarrier ¶

func (b *Raft) WaitForBarrier() error

WaitForBarrier to let fsm finish