From bcf73cdf3456bbcce79d90cd28d88294ea64aff1 Mon Sep 17 00:00:00 2001
From: Yilin Chen <sticnarf@gmail.com>
Date: Thu, 15 Aug 2019 11:55:53 +0800
Subject: [PATCH] Set verion in mvcc apis

Signed-off-by: Yilin Chen <sticnarf@gmail.com>
---
 src/kv_client/requests/mvcc.rs | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/src/kv_client/requests/mvcc.rs b/src/kv_client/requests/mvcc.rs
index 1c463df..c73e892 100644
--- a/src/kv_client/requests/mvcc.rs
+++ b/src/kv_client/requests/mvcc.rs
@@ -32,6 +32,7 @@ impl KvRequest for MvccGet {
     ) -> Self::RpcRequest {
         let mut req = store.request::<Self::RpcRequest>();
         req.set_key(key.into());
+        req.set_version(self.version);
 
         req
     }
@@ -50,7 +51,7 @@ impl KvRequest for MvccGet {
 
     fn map_result(mut resp: Self::RpcResponse) -> Self::Result {
         let result: Value = resp.take_value().into();
-        if result.is_empty() {
+        if resp.not_found {
             None
         } else {
             Some(result)
@@ -89,6 +90,7 @@ impl KvRequest for MvccBatchGet {
     ) -> Self::RpcRequest {
         let mut req = store.request::<Self::RpcRequest>();
         req.set_keys(keys.into_iter().map(Into::into).collect());
+        req.set_version(self.version);
 
         req
     }
@@ -152,6 +154,7 @@ impl KvRequest for MvccScan {
         req.set_end_key(end_key.into());
         req.set_limit(self.limit);
         req.set_key_only(self.key_only);
+        req.set_version(self.version);
 
         req
     }