type Ready struct {
	// 软状态，可变且不需要写入WAL
    // 包含：集群Leader, 节点的当前状态(角色)
	*SoftState	
    // 硬状态，需要持久化到磁盘中
    // 包含：节点的Term, Vote(票投给谁), Commit(已提交的日志索引)
	pb.HardState
	// 用于读一致性的数据，之后会说明
	ReadStates []ReadState
    // 下面的Messages发送前需要持久化到磁盘的日志项
	Entries []pb.Entry
	// 需要持久化的快照数据
	Snapshot pb.Snapshot
	// 已被提交的日志项
    // 这些日志需要上层读取并应用到状态机中
	CommittedEntries []pb.Entry
	// 上面Entries持久化后，需要发送的消息
	Messages []pb.Message
    // HardState和Entries是否需要同步持久化到磁盘
	MustSync bool
}

type Node interface {
    // 增加内部的逻辑时钟，用于驱动选举、心跳等。
    // 上层需要定时调用该方法(如用Ticker控制)。
    Tick()
    // 将角色变成Candidate, 参与Leader选举
    Campaign(ctx context.Context) error
    // 往Raft的日志追加数据，可能返回错误 
    Propose(ctx context.Context, data []byte) error
    // 往Raft写入集群配置变更数据
    ProposeConfChange(ctx context.Context, cc pb.ConfChangeI) error
    // 将消息灌入状态机
    Step(ctx context.Context, msg pb.Message) error
    // 返回一个Ready通道
    // 如2.1.所述，上层可通过轮询这个通道获取哪些数据需要持久化/应用到状态机/发送到其他节点
    Ready() <-chan Ready
    // 调用Ready后，需要执行该方法
    Advance()
    // ...
}

func (rc *raftNode) serveChannels() {
	// ...
	// send proposals over raft
	go func() {
		confChangeCount := uint64(0)
		for rc.proposeC != nil && rc.confChangeC != nil {
            // 从proposeC和confChangeC读取数据，并调用Propose和ProposeConfChange
			select {
			case prop, ok := <-rc.proposeC:
				if !ok {
					rc.proposeC = nil
				} else {
                    // Propose: 向Raft追加日志
					rc.node.Propose(context.TODO(), []byte(prop))
				}

			case cc, ok := <-rc.confChangeC:
				if !ok {
					rc.confChangeC = nil
				} else {
					confChangeCount++
					cc.ID = confChangeCount
                    // ProposeConfChange: 往Raft写入集群配置变更数据
					rc.node.ProposeConfChange(context.TODO(), cc)
				}
			}
		}
		close(rc.stopc)
	}()
    // ...
}

func (rc *raftNode) serveChannels() {
	// ...
    // 设置Ticker, 100ms触发一次事件
    ticker := time.NewTicker(100 * time.Millisecond)
	defer ticker.Stop()
    // ...
    // 轮询Ready
    for {
		select {
        // Ticker就绪时，自增raftNode的逻辑时钟以触发选主, 心跳等
		case <-ticker.C:
			rc.node.Tick()

		// 轮询Ready通道，若就绪，上层则执行必要的事情
		case rd := <-rc.node.Ready():
            // a. 将硬状态和Entries写入WAL
			rc.wal.Save(rd.HardState, rd.Entries) 
            // b. 持久化快照数据
			if !raft.IsEmptySnap(rd.Snapshot) {
				rc.saveSnap(rd.Snapshot)
				rc.raftStorage.ApplySnapshot(rd.Snapshot)
				rc.publishSnapshot(rd.Snapshot)
			}
            // c. 持久化Entries
			rc.raftStorage.Append(rd.Entries)
            // d. 发送Messages给其他节点
			rc.transport.Send(rd.Messages)
            // e. 提取已经提交的日志项，应用到键值存储中(即状态机)
			if ok := rc.publishEntries(rc.entriesToApply(rd.CommittedEntries)); !ok {
				rc.stop()
				return
			}
            // f. 可能触发快照
			rc.maybeTriggerSnapshot()
            // g. 最后需要调用Advance
			rc.node.Advance()

		// ...
		}
	}
}