Struct RetrievalOrchestrator 

pub struct RetrievalOrchestrator { /* private fields */ }

Retrieval pipeline orchestrator.

Coordinates stage execution with:

• Dependency resolution via topological sort
• Parallel execution of independent stages
• Backtracking support for incremental retrieval
• Configurable failure policies
• Pilot integration for intelligent navigation

Example

let orchestrator = RetrievalOrchestrator::new()
    .stage(AnalyzeStage::new())
    .stage(PlanStage::new())
    .stage(SearchStage::new())
    .stage(JudgeStage::new())
    .with_pilot(pilot)
    .with_max_backtracks(3);

let response = orchestrator.execute(tree, query, options).await?;

Implementations

impl RetrievalOrchestrator

pub fn new() -> Self

Create a new empty orchestrator.

pub fn stage<S>(self, stage: S) -> Self

where S: RetrievalStage + 'static,

Add a stage to the pipeline.

Dependencies are read from the stage’s depends_on() method.

pub fn with_pilot(self, pilot: Arc<dyn Pilot>) -> Self

Add Pilot for navigation guidance during backtracking.

When set, the Pilot will be consulted during backtracking to provide intelligent guidance on alternative search paths.

pub fn with_max_backtracks(self, n: usize) -> Self

Set maximum number of backtracks allowed.

pub fn with_max_iterations(self, n: usize) -> Self

Set maximum total iterations.

pub async fn execute( &mut self, tree: Arc<DocumentTree>, query: &str, options: RetrieveOptions, ) -> Result<RetrieveResponse>

Execute the retrieval pipeline.

pub fn stage_names(&self) -> Result<Vec<&str>>

Get list of stage names in execution order.

pub fn get_execution_groups(&self) -> Result<Vec<ExecutionGroup>>

Get execution groups for visualization.

Trait Implementations

impl Default for RetrievalOrchestrator

fn default() -> Self

Returns the “default value” for a type.