pub(crate) struct EarlyStream {
pub(crate) data: Vec<u8>,
pub(crate) done: bool,
pub(crate) truncated: bool,
pub(super) tail: Tail<STDERR_TAIL_SIZE>,
}Expand description
The output of a pipe up to ContainerIO::MAX_STDIO_STREAM_SIZE.
Fields§
§data: Vec<u8>§done: boolWhether the output ended.
truncated: boolWhether output got dropped because of the size limit. Nothing may be appended then, it would leave a gap.
tail: Tail<STDERR_TAIL_SIZE>The end of the output which got dropped, where the error of a runtime
which failed is, up to STDERR_TAIL_SIZE.
Implementations§
Trait Implementations§
Source§impl Debug for EarlyStream
impl Debug for EarlyStream
Auto Trait Implementations§
impl Freeze for EarlyStream
impl RefUnwindSafe for EarlyStream
impl Send for EarlyStream
impl Sync for EarlyStream
impl Unpin for EarlyStream
impl UnsafeUnpin for EarlyStream
impl UnwindSafe for EarlyStream
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].