Struct BoundedProcessExecutor 

pub struct BoundedProcessExecutor { /* private fields */ }

Runs every command with its own deadline.

CancellableProcessExecutor::with_timeout bounds a whole operation from a single shared deadline, which suits one provisioning run. Prerequisite probes are different: each one is expected to answer quickly, and a wedged socket or blackholed network must not stall the probes that follow it. A timeout here names the probe that hung, so the caller can report it the same way it reports any other probe failure.

Implementations

impl BoundedProcessExecutor

pub const fn new(timeout: Duration) -> BoundedProcessExecutor

Trait Implementations

impl Clone for BoundedProcessExecutor

fn clone(&self) -> BoundedProcessExecutor

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl CommandExecutor for BoundedProcessExecutor

fn execute(&self, command: &CommandSpec) -> Result<CommandOutput, Error>

fn execute_with_stdin( &self, command: &CommandSpec, input: &mut (dyn Read + Send), ) -> Result<CommandOutput, Error>

fn cancellation_requested(&self) -> bool

Whether the operation supervising this executor has requested cancellation. Test executors and ordinary process execution are not cancellable unless they opt in.

fn stage_started(&self, _stage: ProvisionStage)

Report entry into a lifecycle stage. Callers that cover more than one command should hold a ProvisionStageGuard for the whole operation so concurrent stages remain visible between subprocesses.

fn stage_finished(&self, _stage: ProvisionStage)

Report exit from a lifecycle stage previously passed to Self::stage_started.

fn notify_notice(&self, _notice: &str)

Report a decision an operation made on the user’s behalf. This is not a failure: the work continues, and the user is told what changed.

impl Copy for BoundedProcessExecutor

impl Debug for BoundedProcessExecutor

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

Formats the value using the given formatter.