package pbs

Get desktop application:
View/edit binary Protocol Buffers messages

• rpc RequestVote (RequestVoteRequest, RequestVoteResponse)

  raftbasic.proto:190

  message RequestVoteRequest

  raftbasic.proto:10

  raft basic request vote definition

  • int64 term = 1

  • int64 candidate_id = 2

  • int64 last_log_index = 3

  • int64 last_log_term = 4

  message RequestVoteResponse

  raftbasic.proto:20

  raft basic request vote response

  • int64 term = 1

  • bool vote_granted = 2

• rpc AppendEntries (AppendEntriesRequest, AppendEntriesResponse)

  raftbasic.proto:191

  message AppendEntriesRequest

  raftbasic.proto:48

  raft basic append entries request definition

  • int64 term = 1

  • int64 leader_id = 2

  • int64 prev_log_index = 3

  • int64 prev_log_term = 4

  • int64 leader_commit = 5

  • repeated Entry entries = 6

  message AppendEntriesResponse

  raftbasic.proto:60

  raft basic append entries response definition

  • int64 term = 1

  • bool success = 2

  • int64 conflict_index = 3

  • int64 conflict_term = 4

• rpc DoCommand (CommandRequest, CommandResponse)

  raftbasic.proto:192

  message CommandRequest

  raftbasic.proto:96

  client command request

  • string key = 1

  • string value = 2

  • OpType op_type = 3

  • int64 client_id = 4

  • int64 command_id = 5

  • bytes context = 6

  message CommandResponse

  raftbasic.proto:108

  client command response

  • string value = 1

  • int64 leader_id = 2

  • int64 err_code = 3

• rpc DoConfig (ConfigRequest, ConfigResponse)

  raftbasic.proto:193

  message ConfigRequest

  raftbasic.proto:130

  config server request to manager the server config table

  • map<int64, string> servers = 1

    gid -> [s1, s2, s3]

  • repeated int64 gids = 2

  • int64 bucket_id = 3

  • int64 gid = 4

  • int64 config_version = 5

  • ConfigOpType op_type = 6

  • int64 client_id = 7

  • int64 command_id = 8

  message ConfigResponse

  raftbasic.proto:150

  • string err_msg = 1

  • optional ServerConfig config = 2

  • int64 leader_id = 3

  • int64 err_code = 4

• rpc DoBucketsOperation (BucketOperationRequest, BucketOperationResponse)

  raftbasic.proto:194

  message BucketOperationRequest

  raftbasic.proto:163

  • int64 config_version = 1

  • repeated int64 bucket_ids = 2

  • BucketOpType bucket_op_type = 3

  • int64 gid = 4

  • bytes buckets_datas = 5

  message BucketOperationResponse

  raftbasic.proto:171

  • int64 config_version = 1

  • bytes buckets_datas = 2

  • string err_msg = 3

• rpc Snapshot (InstallSnapshotRequest, InstallSnapshotResponse)

  raftbasic.proto:195

  message InstallSnapshotRequest

  raftbasic.proto:177

  • int64 term = 1

  • int64 leader_id = 2

  • int64 last_included_index = 3

  • int64 last_included_term = 4

  • bytes data = 5

  message InstallSnapshotResponse

  raftbasic.proto:185

  • int64 term = 1

apply message definition

• bool CommandValid = 1

• bytes Command = 2

• int64 CommandTerm = 3

• int64 CommandIndex = 4

• bool SnapshotValid = 5

• bytes Snapshot = 6

• int64 SnapshotTerm = 7

• int64 SnapshotIndex = 8

Used in: BucketOperationRequest

• OpGetData = 0

• OpDeleteData = 1

• OpInsertData = 2

config client op type

Used in: ConfigRequest

• OpJoin = 0

• OpLeave = 1

• OpMove = 2

• OpQuery = 3

• OpSetBucket = 4

• OpMigBucket = 5

raft basic log entry definition

Used in: AppendEntriesRequest

• EntryType entry_type = 1

• uint64 term = 2

• int64 index = 3

• bytes data = 4

the log entry type 1.normal -> like put, get key 2.conf change -> cluster config change

Used in: Entry

• EntryNormal = 0

• EntryConfChange = 1

client op type

Used in: CommandRequest

• OpPut = 0

• OpAppend = 1

• OpGet = 2

• OpConfigChange = 3

• OpDeleteBuckets = 4

• OpInsertBuckets = 5

Used in: ConfigResponse

• int64 config_version = 1

• repeated int64 buckets = 2

• map<int64, string> groups = 3

  gid -> [s1, s2, s3]