Struct BarrierScheduler

pub struct BarrierScheduler {
    inner: Arc<Inner>,
    hummock_manager: HummockManagerRef,
}

The sender side of the barrier scheduling queue. Can be cloned and held by other managers to schedule and run barriers.

Fields

inner: Arc<Inner>

hummock_manager: HummockManagerRef

Used for getting the latest snapshot after FLUSH.

Implementations

impl BarrierScheduler

pub fn new_pair( hummock_manager: HummockManagerRef, metrics: Arc<MetaMetrics>, ) -> (Self, ScheduledBarriers)

Create a pair of BarrierScheduler and ScheduledBarriers, for scheduling barriers from different managers, and executing them in the barrier manager, respectively.

fn push( &self, scheduleds: impl IntoIterator<Item = ScheduledQueueItem>, ) -> MetaResult<()>

Push a scheduled barrier into the queue.

pub fn try_cancel_scheduled_create(&self, table_id: TableId) -> bool

Try to cancel scheduled cmd for create streaming job, return true if cancelled.

async fn run_multiple_commands( &self, database_id: DatabaseId, commands: Vec<Command>, ) -> MetaResult<()>

Run multiple commands and return when they’re all completely finished. It’s ensured that multiple commands are executed continuously.

Returns the barrier info of each command.

TODO: atomicity of multiple commands is not guaranteed.

pub async fn run_config_change_command_with_pause( &self, database_id: DatabaseId, command: Command, ) -> MetaResult<()>

Run a command with a Pause command before and Resume command after it. Used for configuration change.

Returns the barrier info of the actual command.

pub async fn run_command( &self, database_id: DatabaseId, command: Command, ) -> MetaResult<()>

Run a command and return when it’s completely finished.

Returns the barrier info of the actual command.

pub async fn flush( &self, database_id: DatabaseId, ) -> MetaResult<HummockVersionId>

Flush means waiting for the next barrier to collect.

Trait Implementations

impl Clone for BarrierScheduler

fn clone(&self) -> BarrierScheduler

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.