pub struct StandardEvolutionPipeline { /* private fields */ }Expand description
Standard evolution pipeline implementation
Implementations§
Source§impl StandardEvolutionPipeline
impl StandardEvolutionPipeline
Sourcepub fn new(config: EvolutionPipelineConfig, selector: Arc<dyn Selector>) -> Self
pub fn new(config: EvolutionPipelineConfig, selector: Arc<dyn Selector>) -> Self
Create a pipeline with a mandatory selector and no injected ports. Detect will pass through pre-populated signals; Execute will use a no-op stub that records a synthetic success result.
Sourcepub fn with_signal_extractor(
self,
extractor: Arc<dyn SignalExtractorPort>,
) -> Self
pub fn with_signal_extractor( self, extractor: Arc<dyn SignalExtractorPort>, ) -> Self
Attach a SignalExtractorPort for the Detect stage.
Sourcepub fn with_task_class_inferencer(self, inferencer: TaskClassInferencer) -> Self
pub fn with_task_class_inferencer(self, inferencer: TaskClassInferencer) -> Self
Attach a TaskClassInferencer for the Detect stage.
When attached the Detect stage automatically infers the task class from
collected signals and stores the result in
PipelineResult::inferred_task_class_id. If not attached, inference is
skipped and the field is None.
Sourcepub fn with_default_task_class_inferencer(self) -> Self
pub fn with_default_task_class_inferencer(self) -> Self
Attach a TaskClassInferencer pre-loaded with the current
load_task_classes() registry (builtin + optional TOML override).
Sourcepub fn with_sandbox(self, sandbox: Arc<dyn SandboxPort>) -> Self
pub fn with_sandbox(self, sandbox: Arc<dyn SandboxPort>) -> Self
Attach a SandboxPort for the Execute stage.
Sourcepub fn with_gene_store(self, gene_store: Arc<dyn GeneStorePersistPort>) -> Self
pub fn with_gene_store(self, gene_store: Arc<dyn GeneStorePersistPort>) -> Self
Attach a GeneStorePersistPort for the Solidify/Reuse stages.
Sourcepub fn with_validate_port(self, validator: Arc<dyn ValidatePort>) -> Self
pub fn with_validate_port(self, validator: Arc<dyn ValidatePort>) -> Self
Attach a ValidatePort for the Validate stage.
Sourcepub fn with_evaluate_port(self, evaluator: Arc<dyn EvaluatePort>) -> Self
pub fn with_evaluate_port(self, evaluator: Arc<dyn EvaluatePort>) -> Self
Attach an EvaluatePort for the Evaluate stage.
Trait Implementations§
Source§impl EvolutionPipeline for StandardEvolutionPipeline
impl EvolutionPipeline for StandardEvolutionPipeline
Source§fn config(&self) -> &EvolutionPipelineConfig
fn config(&self) -> &EvolutionPipelineConfig
Source§fn execute(
&self,
context: PipelineContext,
) -> Result<PipelineResult, PipelineError>
fn execute( &self, context: PipelineContext, ) -> Result<PipelineResult, PipelineError>
Source§fn execute_stage(
&self,
stage: PipelineStage,
context: &mut PipelineContext,
) -> Result<PipelineStageState, PipelineError>
fn execute_stage( &self, stage: PipelineStage, context: &mut PipelineContext, ) -> Result<PipelineStageState, PipelineError>
Use execute() instead