Skip to content

Commit 8510d74

Browse files
committed
refactor: minor refactor
1 parent 6ebc963 commit 8510d74

File tree

18 files changed

+340
-383
lines changed

18 files changed

+340
-383
lines changed

src/common/meta/src/ddl_manager.rs

+2-2
Original file line numberDiff line numberDiff line change
@@ -834,7 +834,7 @@ mod tests {
834834
use std::sync::Arc;
835835

836836
use common_procedure::local::LocalManager;
837-
use common_procedure::test_util::InMemoryPoisonManager;
837+
use common_procedure::test_util::InMemoryPoisonStore;
838838

839839
use super::DdlManager;
840840
use crate::cache_invalidator::DummyCacheInvalidator;
@@ -884,7 +884,7 @@ mod tests {
884884
));
885885

886886
let state_store = Arc::new(KvStateStore::new(kv_backend.clone()));
887-
let poison_manager = Arc::new(InMemoryPoisonManager::default());
887+
let poison_manager = Arc::new(InMemoryPoisonStore::default());
888888
let procedure_manager = Arc::new(LocalManager::new(
889889
Default::default(),
890890
state_store,

src/common/meta/src/key.rs

+1-1
Original file line numberDiff line numberDiff line change
@@ -154,9 +154,9 @@ use crate::key::table_route::TableRouteKey;
154154
use crate::key::txn_helper::TxnOpGetResponseSet;
155155
use crate::kv_backend::txn::{Txn, TxnOp};
156156
use crate::kv_backend::KvBackendRef;
157-
use crate::poison_manager::PoisonValue;
158157
use crate::rpc::router::{region_distribution, LeaderState, RegionRoute};
159158
use crate::rpc::store::BatchDeleteRequest;
159+
use crate::state_store::PoisonValue;
160160
use crate::DatanodeId;
161161

162162
pub const NAME_PATTERN: &str = r"[a-zA-Z_:-][a-zA-Z0-9_:\-\.@#]*";

src/common/meta/src/lib.rs

-1
Original file line numberDiff line numberDiff line change
@@ -37,7 +37,6 @@ pub mod metrics;
3737
pub mod node_expiry_listener;
3838
pub mod node_manager;
3939
pub mod peer;
40-
pub mod poison_manager;
4140
pub mod range_stream;
4241
pub mod region_keeper;
4342
pub mod region_registry;

src/common/meta/src/poison_manager.rs

-274
This file was deleted.

0 commit comments

Comments
 (0)