Struct LocalBarrierManager

pub struct LocalBarrierManager {
    barrier_event_sender: UnboundedSender<LocalBarrierEvent>,
    actor_failure_sender: UnboundedSender<(ActorId, StreamError)>,
}

Fields

barrier_event_sender: UnboundedSender<LocalBarrierEvent>

actor_failure_sender: UnboundedSender<(ActorId, StreamError)>

Implementations

impl LocalBarrierManager

fn update_create_mview_progress( &self, epoch: EpochPair, actor: ActorId, state: BackfillState, )

impl LocalBarrierManager

pub(crate) fn register_create_mview_progress( &self, backfill_actor_id: ActorId, ) -> CreateMviewProgressReporter

Create a struct for reporting the progress of creating mview. The backfill executors should report the progress of barrier rearranging continuously using this. The updated progress will be collected by the local barrier manager and reported to the meta service in this epoch.

When all backfill executors of the creating mview finish, the creation progress will be done at frontend and the mview will be exposed to the user.

impl LocalBarrierManager

fn send_event(&self, event: LocalBarrierEvent)

pub fn collect<M>(&self, actor_id: ActorId, barrier: &BarrierInner<M>)

When a crate::executor::StreamConsumer (typically crate::executor::DispatchExecutor) get a barrier, it should report and collect this barrier with its own actor_id using this function.

pub fn notify_failure(&self, actor_id: ActorId, err: StreamError)

When a actor exit unexpectedly, it should report this event using this function, so meta will notice actor’s exit while collecting.

pub fn subscribe_barrier(&self, actor_id: ActorId) -> UnboundedReceiver<Barrier>

Trait Implementations

impl Clone for LocalBarrierManager

fn clone(&self) -> LocalBarrierManager

Returns a copy of the value.

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

Performs copy-assignment from source.