raft

func NewKVStore ¶ added in v0.0.57

func NewKVStore(etcdclient *clientv3.Client, snapshotter *snap.Snapshotter, channels *channels.Cluster, commitC <-chan *Commit, errorC <-chan error, dataC chan KV.KV, node *node.Node, replay bool) (*KVStore, error)

func NewRaftNode ¶ added in v0.0.57

func NewRaftNode(
	keys *keys.Keys,
	TLSConfig *tls.Config,
	id uint64,
	peers *node.Nodes,
	join bool,
	replay bool,
	getSnapshot func() ([]byte, error),
	channels *channels.Cluster,
	config *configuration.RaftConfiguration,
) (*RaftNode, <-chan *Commit, <-chan error, <-chan *snap.Snapshotter)

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.