pub(crate) struct StopOutput {
attach: SharedContainerAttach,
exited: CancellationToken,
}Expand description
Stops the output of an exec once dropped by the consumer of its output,
after the process exited, see SharedContainerAttach::stop_output.
Without exit files, the consumer decides when the output is complete: a
slow one blocks the read loops, which a stop after a pause of the output
would cut off with data left in the pipes. A consumer which went away
before the exit takes nothing anymore, the output stops with the exit.
Fields§
§attach: SharedContainerAttach§exited: CancellationTokenTrait Implementations§
Source§impl Drop for StopOutput
impl Drop for StopOutput
Auto Trait Implementations§
impl Freeze for StopOutput
impl RefUnwindSafe for StopOutput
impl Send for StopOutput
impl Sync for StopOutput
impl Unpin for StopOutput
impl UnsafeUnpin for StopOutput
impl UnwindSafe for StopOutput
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].