Skip to main content

Staged

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

Implementors§