Struct PipelineExecutor 

pub struct PipelineExecutor;

Executes multi-stage command pipelines.

Implementations

impl PipelineExecutor

pub const fn new() -> Self

Create a new pipeline executor.

pub fn execute<'a>( &'a self, stages: &'a [PipelineStage], default_timeout: Duration, ) -> BoxFuture<'a, Result<PipelineResult, VfsError>>

Execute a pipeline: each stage’s stdout is piped to the next stage’s stdin.

pub fn execute_to_file<'a>( &'a self, stages: &'a [PipelineStage], output_file: &'a str, default_timeout: Duration, ) -> BoxFuture<'a, Result<PipelineResult, VfsError>>

Redirect final stage stdout to a file.

Trait Implementations

impl Clone for PipelineExecutor

fn clone(&self) -> PipelineExecutor

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PipelineExecutor

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for PipelineExecutor

fn default() -> PipelineExecutor

Returns the “default value” for a type.