chore(meta): remove unused obsolete message types

Author: drmingdrmer

src/meta/client/src/grpc_action.rs

@@ -45,20 +45,6 @@ pub trait RequestFor {
     type Reply;
 }
 
-// TODO: reduce this and MetaGrpcReadReq into one enum?
-// Action wrapper for do_action.
-#[derive(serde::Serialize, serde::Deserialize, Clone, Debug, derive_more::From)]
-pub enum MetaGrpcWriteReq {
-    UpsertKV(UpsertKVReq),
-}
-
-#[derive(serde::Serialize, serde::Deserialize, Clone, Debug, derive_more::From)]
-pub enum MetaGrpcReadReq {
-    GetKV(GetKVReq),
-    MGetKV(MGetKVReq),
-    ListKV(ListKVReq), // since 2022-05-23
-}
-
 #[derive(serde::Serialize, serde::Deserialize, Clone, Debug, derive_more::From)]
 pub enum MetaGrpcReq {
     UpsertKV(UpsertKVReq),
@@ -81,15 +67,6 @@ impl TryInto<MetaGrpcReq> for Request<RaftRequest> {
     }
 }
 
-impl tonic::IntoRequest<RaftRequest> for MetaGrpcWriteReq {
-    fn into_request(self) -> Request<RaftRequest> {
-        let raft_request = RaftRequest {
-            data: serde_json::to_string(&self).expect("fail to serialize"),
-        };
-        tonic::Request::new(raft_request)
-    }
-}
-
 impl TryInto<Request<RaftRequest>> for MetaGrpcReq {
     type Error = serde_json::Error;
 
@@ -103,32 +80,6 @@ impl TryInto<Request<RaftRequest>> for MetaGrpcReq {
     }
 }
 
-impl TryInto<Request<RaftRequest>> for MetaGrpcWriteReq {
-    type Error = serde_json::Error;
-
-    fn try_into(self) -> Result<Request<RaftRequest>, Self::Error> {
-        let raft_request = RaftRequest {
-            data: serde_json::to_string(&self)?,
-        };
-
-        let request = tonic::Request::new(raft_request);
-        Ok(request)
-    }
-}
-
-impl TryInto<Request<RaftRequest>> for MetaGrpcReadReq {
-    type Error = serde_json::Error;
-
-    fn try_into(self) -> Result<Request<RaftRequest>, Self::Error> {
-        let get_req = RaftRequest {
-            data: serde_json::to_string(&self)?,
-        };
-
-        let request = tonic::Request::new(get_req);
-        Ok(request)
-    }
-}
-
 impl RequestFor for GetKVReq {
     type Reply = GetKVReply;
 }

src/meta/client/src/lib.rs

@@ -17,9 +17,7 @@ mod grpc_client;
 mod kv_api_impl;
 mod message;
 
-pub use grpc_action::MetaGrpcReadReq;
 pub use grpc_action::MetaGrpcReq;
-pub use grpc_action::MetaGrpcWriteReq;
 pub use grpc_action::RequestFor;
 pub use grpc_client::ClientHandle;
 pub use grpc_client::MetaGrpcClient;