raft

type IncomingRPCMsg struct {
	SourceId ServerId
	Msg      RPCMsg
}

type LogEntry struct {
	Term Term
	Data []byte
}

type LogIndex int64

type LogReplayFunc func(*LogEntry) error

type LogStore struct {
	// contains filtered or unexported fields
}

type Logger interface {
	Debug(int, string, ...interface{})
	Info(string, ...interface{})
	Error(string, ...interface{})
}

type PersistentState struct {
	CurrentTerm Term
	VotedFor    ServerId
}

type PersistentStore struct {
	// contains filtered or unexported fields
}

type RPCAppendEntriesRequest struct {
	Term         Term
	LeaderId     ServerId
	PrevLogIndex LogIndex
	PrevLogTerm  Term
	Entries      []LogEntry
	LeaderCommit LogIndex
}

type RPCAppendEntriesResponse struct {
	Term    Term
	Success bool
}

type RPCMsg interface {
	GetType() string
	GetTerm() Term

	fmt.Stringer
}

type RPCRequestVoteRequest struct {
	Term         Term
	CandidateId  ServerId
	LastLogIndex LogIndex
	LastLogTerm  Term
}

type RPCRequestVoteResponse struct {
	Term        Term
	VoteGranted bool
}

type Server struct {
	Cfg ServerCfg
	Log Logger

	Id            ServerId
	LocalAddress  ServerAddress
	PublicAddress ServerAddress
	// contains filtered or unexported fields
}

type ServerAddress = string

type ServerCfg struct {
	Id      ServerId
	Servers ServerSet

	DataDirectory string

	Logger Logger

	MinElectionTimeout time.Duration
	MaxElectionTimeout time.Duration

	HeartbeatInterval time.Duration

	LogReplayFunc LogReplayFunc
}

type ServerData struct {
	LocalAddress  ServerAddress `json:"local_address"`
	PublicAddress ServerAddress `json:"public_address"`
}

type ServerId = string

type ServerSet map[ServerId]ServerData

type ServerState string

type Term int64