Struct IngestExecutor 

pub struct IngestExecutor<D: LlmDispatch + ?Sized> { /* private fields */ }

The orchestrator. Walks a Pipeline start-to-finish, runs helpers up front (parallel-where-independent), threads outputs into LLM stages with explicit-trust slots, and returns an ExecutionTrace.

Implementations

impl<D: LlmDispatch + ?Sized> IngestExecutor<D>

pub fn new(dispatch: Arc<D>) -> Self

Construct an executor around a dispatch implementation.

pub fn with_max_content_chars(self, cap: usize) -> Self

Builder-style setter for the per-LLM-stage content cap (issue #782 PERF-11). Callers resolve the namespace policy via crate::models::GovernancePolicy::effective_multistep_max_content_chars and thread the value here before calling Self::run.

pub fn telemetry(&self) -> Arc<PromptCacheTelemetry>

Telemetry handle. Used by the MCP tool surface to surface the per-run cache-key trace.

pub fn run( &self, pipeline: &Pipeline, content: &str, candidates: &[MemoryHandle], content_embedding: Option<&[f32]>, namespace: Option<&str>, ) -> Result<ExecutionTrace, ExecutorError>

Run a pipeline against an incoming content blob + candidate memory set.

Errors

• ExecutorError::EmptyPipeline if the descriptor has no stages.
• ExecutorError::InvalidTrustSlot if an LLM stage references a stage index that hasn’t run yet or doesn’t refer to a helper.
• ExecutorError::LlmDispatch if the underlying LLM call fails.