Trait CommandExecutor

Source

pub trait CommandExecutor {
    // Required method
    fn execute(&self, command: &CommandSpec) -> Result<CommandOutput, Error>;

    // Provided methods
    fn execute_cleanup(
        &self,
        command: &CommandSpec,
    ) -> Result<CommandOutput, Error> { ... }
    fn cancellation_requested(&self) -> bool { ... }
    fn stage_started(&self, _stage: ProvisionStage) { ... }
    fn stage_finished(&self, _stage: ProvisionStage) { ... }
    fn notify_notice(&self, _notice: &str) { ... }
    fn before_move_source_stop(
        &self,
    ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + '_>> { ... }
    fn reserve_move_destination(&self) { ... }
    fn begin_resumable_move_work(&self) -> Result<(), Error> { ... }
    fn end_resumable_move_work(&self) -> Result<(), Error> { ... }
    fn execute_with_stdin(
        &self,
        _command: &CommandSpec,
        _input: &mut (dyn Read + Send),
    ) -> Result<CommandOutput, Error> { ... }
}

Required Methods§

Source

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

Provided Methods§

Source

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

Bound cleanup attempts while preserving supervisor cancellation. Durable owners retry interrupted cleanup under the next lifecycle or daemon.

Source

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.

Source

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.

Source