server

type AppendEntries struct {
	// Term is the observed term of the leader.
	Term uint64
	// LeaderId is the ID of the leader.
	LeaderId int32
	// PrevLogIndex is the index of the log entry immediately preceding the new ones.
	PrevLogIndex uint64
	// PrevLogTerm is the term of the log entry immediately preceding the new ones.
	PrevLogTerm uint64
	// Entries are the log entries to append.
	Entries log.LogEntries
	// LeaderCommit is the leader's commit index.
	LeaderCommit uint64
	// ResponseChan is the channel to send the response to.
	ResponseChan chan RPCResponse
}

type ApplyRequest struct {
	// Sn is the serial number of the command.
	Sn int64
	// Command is the command to apply.
	Command []byte
	// ResponseChan is the channel to send the response to.
	ResponseChan chan RPCResponse
}

type OptFunc func(o *options)

type RPCResponse struct {
	// Term is the current term of the node.
	Term uint64
	// Response is the response to the request. It is true if the request was
	// accepted.
	Response bool
}

type RPCServer struct {
	pb.UnimplementedAppendEntriesServer
	pb.UnimplementedVoteServer
	pb.UnimplementedApplyEntryServer
	// contains filtered or unexported fields
}

type Sender interface {
	// SendAppendEntries sends an AppendEntries RPC to the given node.
	SendAppendEntries(ctx context.Context, node uint, req AppendEntries) (*RPCResponse, error)
	// SendRequestVote sends a VoteRequest RPC to the given node.
	SendRequestVote(ctx context.Context, node uint, req VoteRequest) (*RPCResponse, error)
}

type Server interface {
	Sender
	// Run starts the server.
	Run(ctx context.Context, peers map[uint]string, testMode bool) error
	// SetVoteRPCChan sets the channel to send vote requests to the fsm.
	SetVoteRPCChan(voteChan chan VoteRequest) Server
	// SetAppendEntryRPCChan sets the channel to send entries to replicate to the fsm.
	SetAppendEntryRPCChan(appendEntriesChan chan AppendEntries) Server
	// SetApplyEntryRPCChan sets the channel to send entries to apply to the fsm.
	SetApplyEntryRPCChan(applyEntryChan chan ApplyRequest) Server
	// Stop stops the server.
	Stop()
}

type VoteRequest struct {
	// Term is the candidate's term.
	Term uint64
	// CandidateId is the candidate requesting the vote.
	CandidateId int32
	// LastLogIndex is the index of the candidate's last log entry.
	LastLogIndex uint64
	// LastLogTerm is the term of the candidate's last log entry.
	LastLogTerm uint64
	// ResponseChan is the channel to send the response to.
	ResponseChan chan RPCResponse
}