Struct PipelineRunner 

pub struct PipelineRunner { /* private fields */ }

Runs pipelines by spawning tasks and connecting them via channels.

Implementations

impl PipelineRunner

pub fn new(tools: Arc<ToolRegistry>) -> Self

Create a new pipeline runner with the given tool registry.

pub async fn run( &self, commands: &[Command], ctx: &mut ExecContext, dispatcher: &dyn CommandDispatcher, ) -> ExecResult

Execute a pipeline of commands.

Each command’s stdout becomes the next command’s stdin. If the pipeline contains scatter/gather, delegates to ScatterGatherRunner. Returns the result of the last command in the pipeline.

The dispatcher handles the full command resolution chain (user tools, builtins, scripts, external commands, backend tools). The runner handles I/O routing: stdin redirects, piping between commands, and output redirects.

pub async fn run_sequential( &self, commands: &[Command], ctx: &mut ExecContext, dispatcher: &dyn CommandDispatcher, ) -> ExecResult

Execute commands sequentially without scatter/gather detection.

Used by ScatterGatherRunner for pre_scatter, post_gather, and parallel workers. Breaks the async recursion chain (run → scatter → run).

Trait Implementations

impl Clone for PipelineRunner

fn clone(&self) -> PipelineRunner

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.