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, database_id: DatabaseId, scheduleds: impl IntoIterator<Item = (Command, Notifier)>, ) -> MetaResult<()>

Push a scheduled barrier into the queue.

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

Try to cancel scheduled cmd for create streaming job, return true if the command exists previously and get 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 (i.e., collected). 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_command( &self, database_id: DatabaseId, command: Command, ) -> MetaResult<()>

Run a command and return when it’s completely finished (i.e., collected).

Returns the barrier info of the actual command.

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

Schedule a command without waiting for it to be executed.

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 duplicate of the value.

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

Performs copy-assignment from source.