mirror of
https://github.com/GreptimeTeam/greptimedb.git
synced 2026-01-09 06:42:57 +00:00
feat: expose RegionMigrationManagerRef (#4812)
* chore: expose `RegionMigrationProcedureTask` * fix: fix typos * chore: expose `tracker`
This commit is contained in:
@@ -43,8 +43,10 @@ use common_procedure::error::{
|
||||
Error as ProcedureError, FromJsonSnafu, Result as ProcedureResult, ToJsonSnafu,
|
||||
};
|
||||
use common_procedure::{Context as ProcedureContext, LockKey, Procedure, Status, StringKey};
|
||||
pub use manager::RegionMigrationProcedureTask;
|
||||
use manager::{RegionMigrationProcedureGuard, RegionMigrationProcedureTracker};
|
||||
use manager::RegionMigrationProcedureGuard;
|
||||
pub use manager::{
|
||||
RegionMigrationManagerRef, RegionMigrationProcedureTask, RegionMigrationProcedureTracker,
|
||||
};
|
||||
use serde::{Deserialize, Serialize};
|
||||
use snafu::{OptionExt, ResultExt};
|
||||
use store_api::storage::RegionId;
|
||||
|
||||
@@ -44,7 +44,7 @@ pub struct RegionMigrationManager {
|
||||
}
|
||||
|
||||
#[derive(Default, Clone)]
|
||||
pub(crate) struct RegionMigrationProcedureTracker {
|
||||
pub struct RegionMigrationProcedureTracker {
|
||||
running_procedures: Arc<RwLock<HashMap<RegionId, RegionMigrationProcedureTask>>>,
|
||||
}
|
||||
|
||||
@@ -149,7 +149,7 @@ impl RegionMigrationManager {
|
||||
}
|
||||
|
||||
/// Returns the [`RegionMigrationProcedureTracker`].
|
||||
pub(crate) fn tracker(&self) -> &RegionMigrationProcedureTracker {
|
||||
pub fn tracker(&self) -> &RegionMigrationProcedureTracker {
|
||||
&self.tracker
|
||||
}
|
||||
|
||||
|
||||
@@ -223,7 +223,7 @@ impl RegionFailureDetectorController for RegionFailureDetectorControl {
|
||||
.send(Event::RegisterFailureDetectors(detecting_regions))
|
||||
.await
|
||||
{
|
||||
error!(err; "RegionSupervisor is stop receiving heartbeat");
|
||||
error!(err; "RegionSupervisor has stop receiving heartbeat.");
|
||||
}
|
||||
}
|
||||
|
||||
@@ -233,7 +233,7 @@ impl RegionFailureDetectorController for RegionFailureDetectorControl {
|
||||
.send(Event::DeregisterFailureDetectors(detecting_regions))
|
||||
.await
|
||||
{
|
||||
error!(err; "RegionSupervisor is stop receiving heartbeat");
|
||||
error!(err; "RegionSupervisor has stop receiving heartbeat.");
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -251,13 +251,13 @@ impl HeartbeatAcceptor {
|
||||
/// Accepts heartbeats from datanodes.
|
||||
pub(crate) async fn accept(&self, heartbeat: DatanodeHeartbeat) {
|
||||
if let Err(err) = self.sender.send(Event::HeartbeatArrived(heartbeat)).await {
|
||||
error!(err; "RegionSupervisor is stop receiving heartbeat");
|
||||
error!(err; "RegionSupervisor has stop receiving heartbeat.");
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
impl RegionSupervisor {
|
||||
/// Returns a a mpsc channel with a buffer capacity of 1024 for sending and receiving `Event` messages.
|
||||
/// Returns a mpsc channel with a buffer capacity of 1024 for sending and receiving `Event` messages.
|
||||
pub(crate) fn channel() -> (Sender<Event>, Receiver<Event>) {
|
||||
tokio::sync::mpsc::channel(1024)
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user