Versions in this module Expand all Collapse all v0 v0.0.2 Nov 9, 2022 Changes in this version + type CfgMember struct + DiscoveryAddress string + NodeID string + RaftAddress string + type CfgPersistence struct + Folder string + type Configuration struct + Members []CfgMember + NodeID string + Persistence CfgPersistence + type RaftConclave struct + func NewRaftConclave(logger *log.Entry, ctx context.Context, wg *sync.WaitGroup, ...) (raftConclave *RaftConclave, err error) + func (raftConclave *RaftConclave) IsLeader() (isLeader bool) + func (raftConclave *RaftConclave) Raft() (raftRaft *raft.Raft) + func (raftConclave *RaftConclave) Run() (err error) + type RaftFSM struct + func (rf *RaftFSM) Apply(raftLog *raft.Log) any + func (rf *RaftFSM) Restore(rc io.ReadCloser) error + func (rf *RaftFSM) Snapshot() (raft.FSMSnapshot, error)