raft

func NewRaftNode ¶

func NewRaftNode(opts pkg_raft.Options, statsCli stats.Client, store db.Store) *raftNode

NewRaftNode initiates a raft instance and returns a committed log entry channel and error channel. Proposals for log updates are sent over the provided the proposal channel. All log entries are replayed over the commit channel, followed by a nil message (to indicate the channel is current), then new log entries. To shutdown, close proposeC and read errorC.

func NewReplicator ¶

func NewReplicator(store db.Store, options pkg_raft.Options) *replicator