Trait mz_adapter::coord::Staged
source · pub(crate) trait Staged: Send {
// Required methods
fn validity(&mut self) -> &mut PlanValidity;
fn stage<'life0, 'life1, 'async_trait>(
self,
coord: &'life0 mut Coordinator,
ctx: &'life1 mut ExecuteContext
) -> Pin<Box<dyn Future<Output = Result<StageResult<Box<Self>>, AdapterError>> + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait;
fn message(self, ctx: ExecuteContext, span: Span) -> Message;
}Expand description
Common functionality for Coordinator::sequence_staged.
Required Methods§
fn validity(&mut self) -> &mut PlanValidity
sourcefn stage<'life0, 'life1, 'async_trait>(
self,
coord: &'life0 mut Coordinator,
ctx: &'life1 mut ExecuteContext
) -> Pin<Box<dyn Future<Output = Result<StageResult<Box<Self>>, AdapterError>> + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn stage<'life0, 'life1, 'async_trait>( self, coord: &'life0 mut Coordinator, ctx: &'life1 mut ExecuteContext ) -> Pin<Box<dyn Future<Output = Result<StageResult<Box<Self>>, AdapterError>> + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,
Returns the next stage or final result.
sourcefn message(self, ctx: ExecuteContext, span: Span) -> Message
fn message(self, ctx: ExecuteContext, span: Span) -> Message
Prepares a message for the Coordinator.
Object Safety§
This trait is not object safe.