leaderelection

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

type HeartBeatMsg struct {
	Lead uint64 // Current leader announcing itself.
	Term uint64 // Current term.
}

type HeartbeatRequest struct {
	Lead uint64
	Term uint64
}

type HeartbeatResponse struct {
	Success bool
	Term    uint64
}

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

type RPC struct {
	Command  any
	RespChan chan RPCResponse
}

type RPCResponse struct {
	Response any
	Error    error
}

type State uint32

type Transport interface {
	// SendVoteRequest sends a vote request message to the given peer.
	SendVoteRequest(ctx context.Context, peer string, msg *VoteRequest, resp *VoteResponse) error
	// SendHeartbeat sends a heartbeat message to the given peer.
	SendHeartbeat(ctx context.Context, peer string, msg *HeartBeatMsg, resp *HeartbeatResponse) error
	// Consumer returns a channel that can be used to
	// consume and respond to RPC requests.
	Consumer() <-chan RPC
}

type VoteRequest struct {
	Candidate uint64 // Candidate requesting vote.
	Term      uint64 // Candidate's term.
}

type VoteResponse struct {
	VoterID uint64
	Term    uint64 // Voter term.
	Granted bool   // True means candidate received vote.
	Reason  string // Used for debugging.
}