Struct CheckpointControl

pub(crate) struct CheckpointControl {
    pub(crate) env: MetaSrvEnv,
    pub(super) databases: HashMap<DatabaseId, DatabaseCheckpointControlStatus>,
    pub(super) hummock_version_stats: HummockVersionStats,
}

Fields

env: MetaSrvEnv

databases: HashMap<DatabaseId, DatabaseCheckpointControlStatus>

hummock_version_stats: HummockVersionStats

Implementations

impl CheckpointControl

pub fn new(env: MetaSrvEnv) -> Self

pub(crate) fn recover( databases: impl IntoIterator<Item = (DatabaseId, DatabaseCheckpointControl)>, failed_databases: HashSet<DatabaseId>, control_stream_manager: &mut ControlStreamManager, hummock_version_stats: HummockVersionStats, env: MetaSrvEnv, ) -> Self

pub(crate) fn ack_completed(&mut self, output: BarrierCompleteOutput)

pub(crate) fn next_complete_barrier_task( &mut self, context: Option<(&mut PeriodicBarriers, &mut ControlStreamManager)>, ) -> Option<CompleteBarrierTask>

pub(crate) fn barrier_collected( &mut self, resp: BarrierCompleteResponse, periodic_barriers: &mut PeriodicBarriers, ) -> MetaResult<()>

pub(crate) fn can_inject_barrier(&self, in_flight_barrier_nums: usize) -> bool

pub(crate) fn max_prev_epoch(&self) -> Option<TracedEpoch>

pub(crate) fn recovering_databases( &self, ) -> impl Iterator<Item = DatabaseId> + '_

pub(crate) fn running_databases(&self) -> impl Iterator<Item = DatabaseId> + '_

pub(crate) fn handle_new_barrier( &mut self, new_barrier: NewBarrier, control_stream_manager: &mut ControlStreamManager, ) -> Option<HashMap<DatabaseId, MetaError>>

return Some(failed database_id -> err)

pub(crate) fn update_barrier_nums_metrics(&self)

pub(crate) fn gen_ddl_progress(&self) -> HashMap<u32, DdlProgress>

pub(crate) fn databases_failed_at_worker_err( &mut self, worker_id: WorkerId, ) -> Vec<DatabaseId>

pub(crate) fn clear_on_err(&mut self, err: &MetaError)

pub(crate) fn inflight_infos( &self, ) -> impl Iterator<Item = (DatabaseId, &InflightSubscriptionInfo, impl Iterator<Item = TableId> + '_)> + '_

impl CheckpointControl

pub(crate) fn on_reset_database_resp( &mut self, worker_id: WorkerId, resp: ResetDatabaseResponse, )

pub(crate) fn next_event( &mut self, ) -> impl Future<Output = CheckpointControlEvent<'_>> + Send + '_

impl CheckpointControl

pub(super) fn new_database_status_action<A>( &mut self, database_id: DatabaseId, action: A, ) -> DatabaseStatusAction<'_, A>

impl CheckpointControl

pub(crate) fn on_report_failure( &mut self, database_id: DatabaseId, control_stream_manager: &mut ControlStreamManager, ) -> Option<DatabaseStatusAction<'_, EnterReset>>