pub(crate) struct WatchedExec {
pub(crate) io: Arc<ContainerIO>,
pub(crate) token: CancellationToken,
pub(crate) process: Arc<Process>,
pub(crate) exit_rx: Receiver<ExitChannelData>,
pub(crate) stop_output: StopOutput,
}Expand description
An exec which got registered, see ChildReaper::watch_exec.
Fields§
§io: Arc<ContainerIO>§token: CancellationTokenCancelled once the process exited.
process: Arc<Process>The process, which its watcher may reap before the token got cancelled, so it does not get signalled by its PID.
exit_rx: Receiver<ExitChannelData>§stop_output: StopOutputStops the output once dropped by its consumer after the exit.
Auto Trait Implementations§
impl !RefUnwindSafe for WatchedExec
impl !UnwindSafe for WatchedExec
impl Freeze for WatchedExec
impl Send for WatchedExec
impl Sync for WatchedExec
impl Unpin for WatchedExec
impl UnsafeUnpin for WatchedExec
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
§impl<T> FutureExt for T
impl<T> FutureExt for T
§fn with_context(self, otel_cx: Context) -> WithContext<Self> ⓘ
fn with_context(self, otel_cx: Context) -> WithContext<Self> ⓘ
§fn with_current_context(self) -> WithContext<Self> ⓘ
fn with_current_context(self) -> WithContext<Self> ⓘ
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request§impl<L> LayerExt<L> for L
impl<L> LayerExt<L> for L
§fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where
L: Layer<S>,
fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where
L: Layer<S>,
Applies the layer to a service and wraps it in [
Layered].