Struct ForwardOp 

pub struct ForwardOp {
    pub cluster: ClusterId,
    pub method: HttpMethod,
    pub path: String,
    pub query: Option<String>,
    pub endpoint: Option<String>,
    pub protocol: Protocol,
    pub trace: Option<TraceContext>,
    pub forward_headers: Vec<(String, String)>,
}

A verbatim forward whose request body is a stream, not buffered bytes (ADR-014 stage 2): the same destination shape as CursorOp but the body is supplied separately as a ByteBody so it can be piped from the downstream connection straight to the upstream without ever being collected. Used by the tenant-agnostic passthrough path.

Fields

cluster: ClusterId

The cluster to forward to.

method: HttpMethod

The HTTP method to forward.

path: String

The upstream path, forwarded verbatim.

query: Option<String>

An already-allow-listed query string (without the ?) to append upstream.

endpoint: Option<String>

The cluster’s base URL, when known (so the pool can be built on any instance). None reuses an existing pool, erroring if none exists.

protocol: Protocol

The upstream wire protocol. Defaults to Protocol::Http1.

trace: Option<TraceContext>

The W3C trace context to forward downstream.

forward_headers: Vec<(String, String)>

Client headers to relay verbatim to the upstream (the forwarding policy’s output). Applied before trace. Empty by default.

Implementations

impl ForwardOp

pub fn new( cluster: ClusterId, method: HttpMethod, path: impl Into<String>, ) -> Self

Constructs a streaming forward op (defaulting to HTTP/1.1 upstream).

pub fn with_forward_headers(self, headers: Vec<(String, String)>) -> Self

Sets the client headers to relay verbatim to the upstream (builder style).

pub fn with_endpoint(self, endpoint: Option<String>) -> Self

Sets the cluster’s base URL (builder style).

pub fn with_query(self, query: Option<String>) -> Self

Sets the (already allow-listed) upstream query string (builder style).

pub fn with_protocol(self, protocol: Protocol) -> Self

Sets the upstream wire protocol (builder style).

pub fn with_trace(self, trace: Option<TraceContext>) -> Self

Sets the trace context to propagate downstream (builder style).

Trait Implementations

impl Clone for ForwardOp

fn clone(&self) -> ForwardOp

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ForwardOp

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

Formats the value using the given formatter.

impl Eq for ForwardOp

impl PartialEq for ForwardOp

fn eq(&self, other: &ForwardOp) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for ForwardOp