server

type CMRole int

type CommandEtnry struct {
	Op   string
	Size int
}

type Config struct {
	LocalID      string   `toml:"localID"`
	IsLearner    bool     `toml:"isLearner"`
	Peers        []string `toml:"peers"`
	Learner      string   `toml:"learner"`
	WalDir       string   `toml:"walDir"`
	SnapDir      string   `toml:"snapDir"`
	MaxIndexSpan uint64   `toml:"maxIndexSpan"`
}

type LogEntry struct {
	Command CommandEtnry
	Term    uint64
	Index   uint64
}

type MessageType int

type Peer struct {
	Addr string
	Role CMRole
}

type Persistence struct {
	Term     uint64
	Index    uint64
	WorkPath string
	FilePath string
}

type RequestAppend struct {
	Type            MessageType
	Term            uint64
	LeaderID        Peer
	PreLogIndex     uint64
	PreLogTerm      uint64
	Entries         []LogEntry
	LeaderCommitted uint64
}

type RequestVote struct {
	Type MessageType
	// 发起投票请求节点的当前任期号
	Term        uint64
	CandidateID Peer
	// 发起投票节点在日志中的最后任期号
	LastTerm uint64
	// 发起投票节点在日志中的最后编号
	LastIndex uint64
}

type ResponseAppend struct {
	Term    uint64
	Success bool
}

type ResponseVote struct {
	// 接收节点所在的任期
	Term uint64
	// true: 赞成; false: 反对
	VoteGranted bool
}

type Server struct {
	// 本节点
	LocalID Peer
	// 集群中其他节点
	Peers []Peer

	// 每个Server既是服务器端, 也是客户端.
	// server接受其他Server的请求
	RpcServer *rpc.Server

	// 状态
	Role CMRole
	// 节点所处的任期
	Term uint64
	// 节点上内存态的命令日志, 待刷入持久化存储
	Logs []LogEntry
	// 投票支持的节点. 空：未投票
	VotedFor Peer
	// 已提交的最新日志编号
	CommittedIndex uint64
	// 已应用到业务逻辑状态机中的最新日志索引
	AppliedIndex uint64
	// 选举超时时间, 开始时间. 每次超时检测完成后, 重置
	ElectionTimeStart time.Time
	// 超时时间间隔, now - ElectionTimeStart > TimeOut, 节点开始发起选举投票
	TimeOut time.Duration
	// 超时时间随机因子
	TimeOutRandomFactor float64
	// 节点状态锁
	MuLock sync.Mutex

	// 持久化存储
	Persist *Persistence
	// 快照处理器
	Snap *Snapshotter

	// 日志中最新apply index 和 日志开头apply index的差值达到
	// MaxIndexSpan, 则可以做快照
	MaxIndexSpan uint64
	// 是否在做快照中
	IsSnaping bool

	// ************* leader 仅有的字段 *******
	// leader记录其他每个Server应该接受的下个日志编号
	NextIndex map[string]uint64
	// contains filtered or unexported fields
}

type Snapshot struct {
	Data     []byte
	Metadata SnapshotMetadata
}

type SnapshotMetadata struct {
	Index uint64
	Term  uint64
}

type Snapshotter struct {
	StartTerm  uint64
	StartIndex uint64
	EndTerm    uint64
	EndIndex   uint64
	WorkPath   string
	FilePath   string
}