risingwave_meta::barrier::context

Trait GlobalBarrierWorkerContext

source
pub(super) trait GlobalBarrierWorkerContext:
    Send
    + Sync
    + 'static {
    // Required methods
    fn commit_epoch(
        &self,
        commit_info: CommitEpochInfo,
    ) -> impl Future<Output = MetaResult<HummockVersionStats>> + Send + '_;
    async fn next_scheduled(&self) -> Scheduled;
    fn abort_and_mark_blocked(&self, recovery_reason: RecoveryReason);
    fn mark_ready(&self);
    fn post_collect_command<'a>(
        &'a self,
        command: &'a CommandContext,
    ) -> impl Future<Output = MetaResult<()>> + Send + 'a;
    async fn notify_creating_job_failed(&self, err: &MetaError);
    fn finish_creating_job(
        &self,
        job: TrackingJob,
    ) -> impl Future<Output = MetaResult<()>> + Send + '_;
    async fn new_control_stream(
        &self,
        node: &WorkerNode,
        init_request: &PbInitRequest,
    ) -> MetaResult<StreamingControlHandle>;
    async fn reload_runtime_info(
        &self,
    ) -> MetaResult<BarrierWorkerRuntimeInfoSnapshot>;
}

Required Methods§

source

fn commit_epoch( &self, commit_info: CommitEpochInfo, ) -> impl Future<Output = MetaResult<HummockVersionStats>> + Send + '_

source

async fn next_scheduled(&self) -> Scheduled

source

fn abort_and_mark_blocked(&self, recovery_reason: RecoveryReason)

source

fn mark_ready(&self)

source

fn post_collect_command<'a>( &'a self, command: &'a CommandContext, ) -> impl Future<Output = MetaResult<()>> + Send + 'a

source

async fn notify_creating_job_failed(&self, err: &MetaError)

source

fn finish_creating_job( &self, job: TrackingJob, ) -> impl Future<Output = MetaResult<()>> + Send + '_

source

async fn new_control_stream( &self, node: &WorkerNode, init_request: &PbInitRequest, ) -> MetaResult<StreamingControlHandle>

source

async fn reload_runtime_info( &self, ) -> MetaResult<BarrierWorkerRuntimeInfoSnapshot>

Object Safety§

This trait is not object safe.

Implementors§