Enum ProxyBody 

pub enum ProxyBody {
    Full(Full<Bytes>),
    Upstream(UpstreamBody),
    Compressed(Box<CompressedBody>),
    Passthrough(PassthroughBody),
    Ai(Box<AiStreamBody>),
    Counted(Box<CountingBody>),
}

Body type of every proxied/gateway-generated response: a small fully-buffered gateway message (Full), the untouched streaming upstream body (UpstreamBody: the pooled stream wrapped with the DW-014 write-timeout / mid-body health-report knobs), a route- compressed stream (crate::dataplane::compression::CompressedBody, DW-027 — the codec wrapper around either of the other two), or an over-cap cache passthrough (crate::dataplane::response_cache::PassthroughBody, DW-037 — the buffered prefix followed by the untouched remainder).

Variants

Full(Full<Bytes>)

Small fully-buffered gateway message (envelope, respond action, metrics/health payloads).

Upstream(UpstreamBody)

Untouched streaming upstream body.

Compressed(Box<CompressedBody>)

Route-compressed response body (DW-027).

Passthrough(PassthroughBody)

Cache over-cap passthrough (DW-037): a body that began buffering for the response cache, crossed the route’s max_body_bytes cap mid-stream, and continues streaming the original bytes exactly as if no cache existed.

Ai(Box<AiStreamBody>)

AI streaming body (DW-077): the provider’s SSE stream translated frame-by-frame into OpenAI-shaped chunks — zero buffering, gateway-owned terminator, infallible by construction (provider aborts become terminal error frames).

Counted(Box<CountingBody>)

Byte-counting wrapper (PERF-12, #209): wraps any of the above to count outbound bytes as they stream to the client, and fires the deferred access-log/analytics callback on stream completion. Always the outermost layer (applied in handle).

Trait Implementations

impl Body for ProxyBody

type Data = Bytes

Values yielded by the Body.

type Error = ProxyBodyError

The error type this Body might generate.

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

Attempt to pull out the next frame of this stream.

fn is_end_stream(&self) -> bool

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

fn size_hint(&self) -> SizeHint

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