pub struct ProcessExecutor;Trait Implementations§
Source§impl CommandExecutor for ProcessExecutor
impl CommandExecutor for ProcessExecutor
fn execute(&self, command: &CommandSpec) -> Result<CommandOutput, Error>
fn execute_with_stdin( &self, command: &CommandSpec, input: &mut (dyn Read + Send), ) -> Result<CommandOutput, Error>
Source§fn execute_cleanup(&self, command: &CommandSpec) -> Result<CommandOutput, Error>
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
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)
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§fn stage_finished(&self, _stage: ProvisionStage)
fn stage_finished(&self, _stage: ProvisionStage)
Report exit from a lifecycle stage previously passed to
Self::stage_started.Source§fn notify_notice(&self, _notice: &str)
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.
Source§fn before_move_source_stop(
&self,
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + '_>>
fn before_move_source_stop( &self, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + '_>>
Stop the source’s children only once destination preparation has succeeded.
Source§fn reserve_move_destination(&self)
fn reserve_move_destination(&self)
The Move source has been sealed; its destination belongs exclusively
to the lifecycle until queue admission completes.
Source§fn begin_resumable_move_work(&self) -> Result<(), Error>
fn begin_resumable_move_work(&self) -> Result<(), Error>
The durable Move owns this interruptible copy; daemon handoff may resume it.
fn end_resumable_move_work(&self) -> Result<(), Error>
Auto Trait Implementations§
impl Freeze for ProcessExecutor
impl RefUnwindSafe for ProcessExecutor
impl Send for ProcessExecutor
impl Sync for ProcessExecutor
impl Unpin for ProcessExecutor
impl UnsafeUnpin for ProcessExecutor
impl UnwindSafe for ProcessExecutor
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
Source§fn in_current_span(self) -> Instrumented<Self> ⓘ
fn in_current_span(self) -> Instrumented<Self> ⓘ
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§impl<T> IntoMaybeUndefined<T> for T
impl<T> IntoMaybeUndefined<T> for T
Source§fn into_maybe_undefined(self) -> MaybeUndefined<T>
fn into_maybe_undefined(self) -> MaybeUndefined<T>
Converts this value into a three-state builder argument.
Source§impl<T> IntoOption<T> for T
impl<T> IntoOption<T> for T
Source§fn into_option(self) -> Option<T>
fn into_option(self) -> Option<T>
Converts this value into an optional builder argument.