raft

type Config struct {
	Callbacks []FSMProcessFunc // Callback functions to be invoked by the FSM after execution is done.

	HeartbeatTimeout time.Duration // How often a consensus cluster leader should ping its followers.
	ElectionTimeout  time.Duration // How long does a consensus cluster node wait for a leader before it triggers an election.
	LeaderLease      time.Duration // How long does a leader remain a leader if it cannot contact a quorum of cluster nodes.
}

type FSMLogEntry struct {
	RequestID string          `json:"request_id,omitempty"`
	Origin    peer.ID         `json:"origin,omitempty"`
	Execute   execute.Request `json:"execute,omitempty"`
}

type FSMProcessFunc func(req FSMLogEntry, res execute.Result)

type Option func(*Config)

type Replica struct {
	*raft.Raft
	// contains filtered or unexported fields
}