Skip to main content

EvolutionPipeline

Trait EvolutionPipeline 

Source
pub trait EvolutionPipeline: Send + Sync {
    // Required methods
    fn name(&self) -> &str;
    fn config(&self) -> &EvolutionPipelineConfig;
    fn execute(
        &self,
        context: PipelineContext,
    ) -> Result<PipelineResult, PipelineError>;
    fn execute_stage(
        &self,
        stage: PipelineStage,
        context: &mut PipelineContext,
    ) -> Result<PipelineStageState, PipelineError>;
}
Expand description

Evolution Pipeline trait

Required Methods§

Source

fn name(&self) -> &str

Get pipeline name

Source

fn config(&self) -> &EvolutionPipelineConfig

Get pipeline configuration

Source

fn execute( &self, context: PipelineContext, ) -> Result<PipelineResult, PipelineError>

Execute the full pipeline

Source

fn execute_stage( &self, stage: PipelineStage, context: &mut PipelineContext, ) -> Result<PipelineStageState, PipelineError>

Execute a specific stage

Implementors§