Struct UpstreamBody 

pub struct UpstreamBody { /* private fields */ }

The error is terminal for the stream: frames already forwarded to the client end abruptly (HTTP/1.1 truncation semantics); it is never retried (an attempt is final once its headers resolved).

Implementations

impl UpstreamBody

pub fn from_incoming( inner: Incoming, idle: Option<Duration>, health: Option<(Arc<UpstreamLb>, HealthDispatch)>, ) -> Self

Wrap a streaming TCP/TLS upstream body (Incoming) with the DW-014 idle/deadline/health knobs. idle is the response-body inactivity timeout (timeouts.write_ms); health carries the dispatch’s passive-health tracker for mid-body failure reporting. The legacy pooled-client path uses this constructor.

pub fn from_buffered(body: Bytes) -> Self

Wrap a fully-buffered H3 response body (DW-108). The H3 transport collects the response into one Bytes (streaming H3 bodies are a follow-up; see dataplane::upstream_h3); the wrapper still applies the deadline knob (the body is already complete, so the idle timer never arms). health is None for H3 today (a buffered body cannot mid-stream abort, so there is no mid-body failure to report).

pub fn from_h3_streaming( rx: Receiver<Result<Bytes, UpstreamBodyError>>, idle: Option<Duration>, health: Option<(Arc<UpstreamLb>, HealthDispatch)>, ) -> Self

Wrap a streaming H3 response body (PERF-10, #243): a channel-backed body that forwards h3 recv_data chunks as they arrive, matching the h1/h2 zero-buffer guarantee. The H3 transport spawns a driver task that reads recv_data from the h3 stream and sends each chunk through the channel; this constructor wraps the receiver as a BoxBody so the idle/deadline/health knobs apply uniformly across transports.

pub fn set_release_permit(&mut self, permit: OwnedSemaphorePermit)

Attach the gateway concurrency-cap permit (DW-015): it releases when this body completes or is dropped, which is exactly the “release at body completion” contract of the global cap.

pub fn set_deadline(&mut self, deadline: Instant)

Arm the ABSOLUTE body deadline (DW-039): set by the proxy from a gRPC request’s grpc-timeout (the deadline that bounded the forward, continuing through the body — the RPC’s total budget).

pub fn set_inflight_guard(&mut self, guard: InflightGuard)

REL-06 (#217): attach the in-flight guard so the endpoint’s in-flight counter is held until the body stream completes (or the body is dropped). Used when body_completion_inflight is enabled in the upstream’s health config.

pub fn empty() -> Self

REL-05 (#216): create an empty body (used as a placeholder while the first-frame buffer drains the real body).

pub fn set_inner(&mut self, inner: BoxBody<Bytes, UpstreamBodyError>)

REL-05 (#216): replace the inner body with a pinned boxed body (the remaining stream after the first-frame buffer drained the prefix). The idle/deadline/health knobs are preserved.

pub fn set_full(&mut self, body: Bytes)

REL-05 (#216): replace the inner body with a fully-buffered Bytes (the body completed within the first-frame buffer).

pub fn with_prefix(prefix: Bytes, rest: UpstreamBody) -> Self

REL-05 (#216): create a body that emits a prefix then continues with rest. Used when the first-frame buffer filled: the prefix is flushed to the client, then the remaining upstream body streams frame-by-frame.

Trait Implementations

impl Body for UpstreamBody

type Data = Bytes

Values yielded by the Body.

type Error = UpstreamBodyError

The error type this Body might generate.

fn poll_frame( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Option<Result<Frame<Bytes>, UpstreamBodyError>>>

Attempt to pull out the next frame of this stream.

fn size_hint(&self) -> SizeHint

A hint that returns the bounds on the remaining length of the stream.

fn is_end_stream(&self) -> bool

A hint that may return true when the end of stream has been reached.

impl Debug for UpstreamBody

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.