Watch 方法
请求的消息体是 WatchRequest
:
message WatchRequest {
// request_union 要么是创建新的观察者的请求,要么是取消一个已经存在的观察者的请求
oneof request_union {
WatchCreateRequest create_request = 1;
WatchCancelRequest cancel_request = 2;
}
}
取消已有观察者的 WatchCancelRequest
:
message WatchCancelRequest {
}
mvccpb.Event 的消息体:
message Event {
enum EventType {
PUT = 0;
DELETE = 1;
}
// type 是事件的类型。
// 如果类型是 PUT,表明新的数据已经存储到 key。
// kv 为事件持有 KeyValue。
// PUT 事件包含当前的kv键值对
// kv.Version=1 的 PUT 事件表明 key 的创建
// DELETE/EXPIRE 事件包含被删除的 key,它的修改修订版本设置为删除的修订版本
KeyValue kv = 2;
// prev_kv 持有在事件发生前的键值对
KeyValue prev_kv = 3;
}