tikv的操作
kvproto-master\proto\raft_cmdpb.proto
message Request {
optional CmdType cmd_type = 1;
optional GetRequest get = 2;
optional PutRequest put = 4;
optional DeleteRequest delete = 5;
optional SnapRequest snap = 6;
}
message RaftCmdRequest {
optional RaftRequestHeader header = 1;
// We can't enclose normal requests and administrator request
// at same time.
repeated Request requests = 2;
optional AdminRequest admin_request = 3;
optional StatusRequest status_request = 4;
}
https://github.com/pingcap/tikv/blob/master/src/raftstore/store/peer.rs#L519
propose触发写raft log
apply_raft_cmd写rocksdb
handle_raft_entry_normal把raft log中传入来,然后调用process_raft_cmd,apply_raft_cmd 写db
handle_raft_commit_entries提交db,把raft log提交上去
propose_normal写put get del raftlog函数peer.rs self.raft_group.propose 最终调用raft.rs 的中append_entry写入