Raft

type AppendEntriesArgs struct {
	Term         int        // leader的任期号
	LeaderID     uint64     // leaderID 便于进行重定向
	PrevLogIndex int        // 新日志之前日志的索引值
	PrevLogTerm  int        // 新日志之前日志的Term
	Entries      []LogEntry // 存储的日志条目 为空时是心跳包
	LeaderCommit int        // leader已经提交的日志的索引
}

type AppendEntriesReply struct {
	CurrentTerm int  // 用于更新leader本身 因为leader可能会出现分区
	Success     bool // follower如果跟上了PrevLogIndex,PrevLogTerm的话为true,否则的话需要与leader同步日志

	// 用于同步日志
	ConflictTerm int // term of the conflicting entry
	FirstIndex   int // the first index it stores for ConflictTerm

	IsOk bool
}

type ApplyMsg struct {
	Index       int
	Command     interface{}
	UseSnapshot bool   // true为快照；false为一般command
	Snapshot    []byte // 快照数据

}

type InstallSnapshotArgs struct {
	Term              int    // 领导人的任期号
	LeaderID          uint64 // 领导人的ID，以便于跟随者重定向请求
	LastIncludedIndex int    // 快照中包含的最后日志条目的索引值
	LastIncludedTerm  int    // 快照中包含的最后日志条目的任期号
	Snapshot          []byte // 快照数据
}

type InstallSnapshotReply struct {
	CurrentTerm int // leader可能已经落后了，用于更新leader

	IsOk bool
}

type LogEntry struct {
	Term    int
	Command interface{}
}

type Raft struct {
	CurrentTerm int        // 服务器最后一次知道的任期号（初始化为 0，持续递增）
	VotedFor    uint64     // 在当前获得选票的候选人的 Id
	Logs        []LogEntry // 日志条目集；每一个条目包含一个用户状态机执行的指令，和收到时的任期号

	ConnectIsok *int32 // 参考RaftKV中的解释
	// contains filtered or unexported fields
}

type RequestVoteArgs struct {
	Term         int    // 候选人的任期号 2A
	CandidateID  uint64 // 请求选票的候选人ID 2A
	LastLogIndex int    // 候选人的最后日志条目的索引值 2A
	LastLogTerm  int    // 候选人的最后日志条目的任期号 2A
}

type RequestVoteReply struct {
	CurrentTerm int  // 当前任期号,便于返回后更新自己的任期号 2A
	VoteGranted bool // 候选人赢得了此张选票时为真 2A

	IsOk bool // 用于告诉请求方对端的服务器是否已经启动
}