Be a little more consistent with the types in request ctor functions

Signed-off-by: Nick Cameron <nrc@ncameron.org>

src/transaction/client.rs

@@ -185,7 +185,7 @@ impl Client {
         let mut start_key = vec![];
         loop {
             let req = new_scan_lock_request(
-                mem::take(&mut start_key),
+                mem::take(&mut start_key).into(),
                 safepoint.clone(),
                 SCAN_LOCK_BATCH_SIZE,
             );

src/transaction/requests.rs

@@ -18,6 +18,7 @@ impl KvRequest for kvrpcpb::GetRequest {
     type Result = Option<Value>;
     type RpcResponse = kvrpcpb::GetResponse;
     type KeyData = Key;
+
     fn store_stream<PdC: PdClient>(
         &mut self,
         pd_client: Arc<PdC>,
@@ -60,9 +61,9 @@ impl HasLocks for kvrpcpb::GetResponse {
     }
 }
 
-pub fn new_mvcc_get_request(key: impl Into<Key>, timestamp: Timestamp) -> kvrpcpb::GetRequest {
+pub fn new_mvcc_get_request(key: Key, timestamp: Timestamp) -> kvrpcpb::GetRequest {
     let mut req = kvrpcpb::GetRequest::default();
-    req.set_key(key.into().into());
+    req.set_key(key.into());
     req.set_version(timestamp.version());
     req
 }
@@ -72,6 +73,7 @@ impl KvRequest for kvrpcpb::BatchGetRequest {
     type Result = Vec<KvPair>;
     type RpcResponse = kvrpcpb::BatchGetResponse;
     type KeyData = Vec<Key>;
+
     fn make_rpc_request(&self, keys: Self::KeyData, store: &Store) -> Result<Self> {
         let mut req = self.request_from_store(store)?;
         req.set_keys(keys.into_iter().map(Into::into).collect());
@@ -153,12 +155,12 @@ impl KvRequest for kvrpcpb::ScanRequest {
 }
 
 pub fn new_mvcc_scan_request(
-    range: impl Into<BoundRange>,
+    range: BoundRange,
     timestamp: Timestamp,
     limit: u32,
     key_only: bool,
 ) -> kvrpcpb::ScanRequest {
-    let (start_key, end_key) = range.into().into_keys();
+    let (start_key, end_key) = range.into_keys();
     let mut req = kvrpcpb::ScanRequest::default();
     req.set_start_key(start_key.into());
     req.set_end_key(end_key.unwrap_or_default().into());
@@ -574,7 +576,7 @@ impl KvRequest for kvrpcpb::PessimisticLockRequest {
 }
 
 pub fn new_pessimistic_lock_request(
-    keys: Vec<impl Into<Key>>,
+    keys: Vec<Key>,
     primary_lock: Key,
     start_version: u64,
     lock_ttl: u64,
@@ -587,7 +589,7 @@ pub fn new_pessimistic_lock_request(
         .map(|key| {
             let mut mutation = kvrpcpb::Mutation::default();
             mutation.set_op(kvrpcpb::Op::PessimisticLock);
-            mutation.set_key(key.into().into());
+            mutation.set_key(key.into());
             mutation
         })
         .collect();
@@ -640,12 +642,12 @@ impl KvRequest for kvrpcpb::ScanLockRequest {
 }
 
 pub fn new_scan_lock_request(
-    start_key: impl Into<Key>,
+    start_key: Key,
     safepoint: Timestamp,
     limit: u32,
 ) -> kvrpcpb::ScanLockRequest {
     let mut req = kvrpcpb::ScanLockRequest::default();
-    req.set_start_key(start_key.into().into());
+    req.set_start_key(start_key.into());
     req.set_max_version(safepoint.version());
     req.set_limit(limit);
     req

src/transaction/transaction.rs

@@ -455,7 +455,8 @@ impl Transaction {
                 }
             }
             TransactionKind::Pessimistic(_) => {
-                self.pessimistic_lock(keys, false).await?;
+                self.pessimistic_lock(keys.into_iter().map(|k| k.into()), false)
+                    .await?;
             }
         }
         Ok(())
@@ -574,7 +575,7 @@ impl Transaction {
     /// Only valid for pessimistic transactions, panics if called on an optimistic transaction.
     async fn pessimistic_lock(
         &mut self,
-        keys: impl IntoIterator<Item = impl Into<Key>>,
+        keys: impl IntoIterator<Item = Key>,
         need_value: bool,
     ) -> Result<Vec<Option<Vec<u8>>>> {
         assert!(
@@ -582,11 +583,7 @@ impl Transaction {
             "`pessimistic_lock` is only valid to use with pessimistic transactions"
         );
 
-        let keys: Vec<Vec<u8>> = keys
-            .into_iter()
-            .map(|it| it.into())
-            .map(|it: Key| it.into())
-            .collect();
+        let keys: Vec<Key> = keys.into_iter().collect();
         let first_key = keys[0].clone();
         let primary_lock = self.buffer.get_primary_key_or(&first_key.into()).await;
         let lock_ttl = DEFAULT_LOCK_TTL;