fix clippy error for rust 1.78

Signed-off-by: Ping Yu <yuping@pingcap.com>

Makefile

@@ -19,6 +19,9 @@ check: generate
 	cargo fmt -- --check
 	cargo clippy --all-targets --features "${ALL_FEATURES}" -- -D clippy::all
 
+clippy:
+	cargo clippy --all-targets --features "${ALL_FEATURES}" -- -D clippy::all
+
 unit-test: generate
 	cargo nextest run --all --no-default-features
 

src/pd/cluster.rs

@@ -49,7 +49,7 @@ impl Cluster {
         timeout: Duration,
     ) -> Result<pdpb::GetRegionResponse> {
         let mut req = pd_request!(self.id, pdpb::GetRegionRequest);
-        req.region_key = key.clone();
+        req.region_key = key;
         req.send(&mut self.client, timeout).await
     }
 
@@ -101,7 +101,7 @@ impl Cluster {
         timeout: Duration,
     ) -> Result<keyspacepb::KeyspaceMeta> {
         let mut req = pd_request!(self.id, keyspacepb::LoadKeyspaceRequest);
-        req.name = keyspace.to_owned();
+        req.name = keyspace.to_string();
         let resp = req.send(&mut self.keyspace_client, timeout).await?;
         let keyspace = resp
             .keyspace

src/raw/requests.rs

@@ -472,7 +472,7 @@ impl Shardable for RawCoprocessorRequest {
 
     fn apply_shard(&mut self, shard: Self::Shard, store: &RegionStore) -> Result<()> {
         self.set_leader(&store.region_with_leader)?;
-        self.inner.ranges = shard.clone();
+        self.inner.ranges.clone_from(&shard);
         self.inner.data = (self.data_builder)(store.region_with_leader.region.clone(), shard);
         Ok(())
     }

src/region_cache.rs

@@ -575,10 +575,10 @@ mod test {
         });
         assert!(!is_valid_tikv_store(&store));
 
-        store.labels[1].value = "tiflash_compute".to_owned();
+        store.labels[1].value = "tiflash_compute".to_string();
         assert!(!is_valid_tikv_store(&store));
 
-        store.labels[1].value = "other".to_owned();
+        store.labels[1].value = "other".to_string();
         assert!(is_valid_tikv_store(&store));
     }
 }

src/store/mod.rs

@@ -8,7 +8,6 @@ use std::cmp::max;
 use std::cmp::min;
 use std::sync::Arc;
 
-use async_trait::async_trait;
 use derive_new::new;
 use futures::prelude::*;
 use futures::stream::BoxStream;
@@ -38,21 +37,6 @@ pub struct Store {
     pub client: Arc<dyn KvClient + Send + Sync>,
 }
 
-#[async_trait]
-pub trait KvConnectStore: KvConnect {
-    async fn connect_to_store(
-        &self,
-        region: RegionWithLeader,
-        address: String,
-    ) -> Result<RegionStore> {
-        log::info!("connect to tikv endpoint: {:?}", &address);
-        let client = self.connect(address.as_str()).await?;
-        Ok(RegionStore::new(region, Arc::new(client)))
-    }
-}
-
-impl KvConnectStore for TikvConnect {}
-
 /// Maps keys to a stream of stores. `key_data` must be sorted in increasing order
 pub fn store_stream_for_keys<K, KOut, PdC>(
     key_data: impl Iterator<Item = K> + Send + Sync + 'static,

src/transaction/buffer.rs

@@ -358,13 +358,13 @@ impl BufferEntry {
             BufferEntry::Cached(_) => return None,
             BufferEntry::Put(v) => {
                 pb.op = kvrpcpb::Op::Put.into();
-                pb.value = v.clone();
+                pb.value.clone_from(v);
             }
             BufferEntry::Del => pb.op = kvrpcpb::Op::Del.into(),
             BufferEntry::Locked(_) => pb.op = kvrpcpb::Op::Lock.into(),
             BufferEntry::Insert(v) => {
                 pb.op = kvrpcpb::Op::Insert.into();
-                pb.value = v.clone();
+                pb.value.clone_from(v);
             }
             BufferEntry::CheckNotExist => pb.op = kvrpcpb::Op::CheckNotExists.into(),
         };