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§
Sourcefn config(&self) -> &EvolutionPipelineConfig
fn config(&self) -> &EvolutionPipelineConfig
Get pipeline configuration
Sourcefn execute(
&self,
context: PipelineContext,
) -> Result<PipelineResult, PipelineError>
fn execute( &self, context: PipelineContext, ) -> Result<PipelineResult, PipelineError>
Execute the full pipeline
Sourcefn execute_stage(
&self,
stage: PipelineStage,
context: &mut PipelineContext,
) -> Result<PipelineStageState, PipelineError>
fn execute_stage( &self, stage: PipelineStage, context: &mut PipelineContext, ) -> Result<PipelineStageState, PipelineError>
Execute a specific stage