Struct CheckpointControl

pub(crate) struct CheckpointControl {
    databases: HashMap<DatabaseId, DatabaseCheckpointControl>,
    hummock_version_stats: HummockVersionStats,
}

Fields

databases: HashMap<DatabaseId, DatabaseCheckpointControl>

hummock_version_stats: HummockVersionStats

Implementations

impl CheckpointControl

pub(crate) fn new( databases: HashMap<DatabaseId, DatabaseCheckpointControl>, hummock_version_stats: HummockVersionStats, ) -> 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, control_stream_manager: &mut ControlStreamManager, ) -> 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 handle_new_barrier( &mut self, new_barrier: NewBarrier, control_stream_manager: &mut ControlStreamManager, active_streaming_nodes: &ActiveStreamingWorkerNodes, ) -> MetaResult<()>

pub(crate) fn update_barrier_nums_metrics(&self)

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

pub(crate) fn is_failed_at_worker_err(&self, worker_id: WorkerId) -> bool

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

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

Trait Implementations

impl Default for CheckpointControl

fn default() -> CheckpointControl

Returns the “default value” for a type.