Trait mz_adapter::coord::Staged

source · 
pub(crate) trait Staged: Send {
    type Ctx: StagedContext;

    // Required methods
    fn validity(&mut self) -> &mut PlanValidity;
    async fn stage(
        self,
        coord: &mut Coordinator,
        ctx: &mut Self::Ctx,
    ) -> Result<StageResult<Box<Self>>, AdapterError>;
    fn message(self, ctx: Self::Ctx, span: Span) -> Message;
    fn cancel_enabled(&self) -> bool;
}
Expand description

Common functionality for Coordinator::sequence_staged.

Required Associated Types§

source

type Ctx: StagedContext

Required Methods§

source

fn validity(&mut self) -> &mut PlanValidity

source

async fn stage( self, coord: &mut Coordinator, ctx: &mut Self::Ctx, ) -> Result<StageResult<Box<Self>>, AdapterError>

Returns the next stage or final result.

source

fn message(self, ctx: Self::Ctx, span: Span) -> Message

Prepares a message for the Coordinator.

source

fn cancel_enabled(&self) -> bool

Whether it is safe to SQL cancel this stage.

Object Safety§

This trait is not object safe.

Implementors§