ISSUE-1639:Remove session_api.rs

common/flights/src/impls/mod.rs

@@ -15,7 +15,6 @@
 
 pub mod kv_api_impl;
 pub mod meta_api_impl;
-pub mod session_api_impl;
 pub mod storage_api_impl;
 pub mod storage_api_impl_utils;
 #[cfg(test)]

common/flights/src/lib.rs

@@ -23,7 +23,6 @@ pub use flight_token::FlightClaim;
 pub use flight_token::FlightToken;
 pub use impls::kv_api_impl;
 pub use impls::meta_api_impl;
-pub use impls::session_api_impl;
 pub use impls::storage_api_impl;
 pub use store_client::StoreClient;
 pub use store_do_action::RequestFor;

common/flights/src/store_do_action.rs

@@ -31,7 +31,6 @@ use crate::impls::meta_api_impl::DropTableAction;
 use crate::impls::meta_api_impl::GetDatabaseAction;
 use crate::impls::meta_api_impl::GetDatabaseMetaAction;
 use crate::impls::meta_api_impl::GetTableAction;
-use crate::impls::session_api_impl::KillQueryReq;
 use crate::impls::storage_api_impl::ReadPlanAction;
 use crate::impls::storage_api_impl::TruncateTableAction;
 use crate::meta_api_impl::GetTableExtReq;
@@ -76,9 +75,6 @@ pub enum StoreDoAction {
     GetKV(GetKVAction),
     MGetKV(MGetKVAction),
     PrefixListKV(PrefixListReq),
-
-    // session
-    KillQuery(KillQueryReq),
 }
 
 /// Try convert tonic::Request<Action> to DoActionAction.

common/store-api/src/lib.rs

@@ -15,7 +15,6 @@
 
 pub mod kv_api;
 mod meta_api;
-mod session_api;
 mod storage_api;
 
 pub use kv_api::GetKVActionResult;
@@ -31,7 +30,6 @@ pub use meta_api::DropTableActionResult;
 pub use meta_api::GetDatabaseActionResult;
 pub use meta_api::GetTableActionResult;
 pub use meta_api::MetaApi;
-pub use session_api::SessionApi;
 pub use storage_api::AppendResult;
 pub use storage_api::BlockStream;
 pub use storage_api::DataPartInfo;

store/src/executor/action_handler.rs

@@ -115,9 +115,6 @@ impl ActionHandler {
             StoreDoAction::GetKV(a) => s.serialize(self.handle(a).await?),
             StoreDoAction::MGetKV(a) => s.serialize(self.handle(a).await?),
             StoreDoAction::PrefixListKV(a) => s.serialize(self.handle(a).await?),
-
-            // session
-            StoreDoAction::KillQuery(a) => s.serialize(self.handle(a).await?),
         }
     }
 

store/src/executor/mod.rs

@@ -21,5 +21,4 @@ pub use action_handler::ReplySerializer;
 mod action_handler_test;
 mod kv_handlers;
 mod meta_handlers;
-mod session_handlers;
 mod storage_handlers;