mz_adapter::coord

Trait 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.

Dyn Compatibility§

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementors§