package raftRpcProctoc

Get desktop application:
View/edit binary Protocol Buffers messages

只有raft节点之间才会涉及rpc通信

• rpc AppendEntries (AppendEntriesArgs, AppendEntriesReply)

  raftRPC.proto:66

  message AppendEntriesArgs

  raftRPC.proto:15

  AppendEntriesArgs 由leader复制log条目，也可以当做是心跳连接，注释中的rf为leader节点

  • int32 Term = 1

    下面几个参数和论文中相同

  • int32 LeaderId = 2

  • int32 PrevLogIndex = 3

  • int32 PrevLogTerm = 4

  • repeated LogEntry Entries = 5

  • int32 LeaderCommit = 6

  message AppendEntriesReply

  raftRPC.proto:26

  AppendEntriesReply 论文中没有提及返回要设置哪些状态

  • int32 Term = 1

    leader的term可能是与Follower不同的，

  • bool Success = 2

  • int32 UpdateNextIndex = 3

    快速调整leader对应的nextIndex

  • int32 AppState = 4

    用来标识节点（网络）状态

• rpc InstallSnapshot (InstallSnapshotRequest, InstallSnapshotResponse)

  raftRPC.proto:67

  message InstallSnapshotRequest

  raftRPC.proto:51

  • int32 LeaderId = 1

  • int32 Term = 2

  • int32 LastSnapShotIncludeIndex = 3

  • int32 LastSnapShotIncludeTerm = 4

  • bytes Data = 5

    快照信息，当然是用bytes来传递

  message InstallSnapshotResponse

  raftRPC.proto:60

  InstallSnapshotResponse 只用返回Term，因为对于快照只要Term是符合的就是无条件接受的

  • int32 Term = 1

• rpc RequestVote (RequestVoteArgs, RequestVoteReply)

  raftRPC.proto:68

  message RequestVoteArgs

  raftRPC.proto:33

  • int32 Term = 1

  • int32 CandidateId = 2

  • int32 LastLogIndex = 3

  • int32 LastLogTerm = 4

  message RequestVoteReply

  raftRPC.proto:43

  RequestVoteReply example RequestVote RPC reply structure. field names must start with capital letters!

  • int32 Term = 1

    Your data here (2A).

  • bool VoteGranted = 2

  • int32 VoteState = 3

日志实体

Used in: AppendEntriesArgs

• bytes Command = 1

• int32 LogTerm = 2

• int32 LogIndex = 3