Struct OutboundClient 

pub struct OutboundClient {
    verified: Client<HttpsConnector<HttpConnector>, Full<Bytes>>,
    insecure: OnceLock<Client<HttpsConnector<HttpConnector>, Full<Bytes>>>,
    custom: RwLock<HashMap<u64, Client<HttpsConnector<HttpConnector>, Full<Bytes>>>>,
}

Process-wide pooled HTTP client.

Fields

verified: Client<HttpsConnector<HttpConnector>, Full<Bytes>>

insecure: OnceLock<Client<HttpsConnector<HttpConnector>, Full<Bytes>>>

Built on first ssl_verify: false request; never constructed on the common path.

custom: RwLock<HashMap<u64, Client<HttpsConnector<HttpConnector>, Full<Bytes>>>>

Clients for per-upstream TLS identities (mTLS / private CA), keyed by the identity’s content hash. Never evicted — bounded by the number of distinct identities ever configured.

Implementations

impl OutboundClient

pub fn new() -> Self

Builds the shared client. TLS uses the platform’s native root store. Advertises both HTTP/1.1 and HTTP/2 via ALPN, so TLS upstreams that support h2 (e.g. gRPC backends) are served over HTTP/2 while plain-http upstreams stay HTTP/1.1.

pub async fn request( &self, req: OutboundRequest, ) -> Result<OutboundResponse, OutboundError>

Performs the request, honoring timeout and ssl_verify.

pub async fn request_streaming( &self, req: OutboundRequest, ) -> Result<OutboundStreamingResponse, OutboundError>

Like request but returns as soon as the response headers arrive, leaving the body to stream. req.timeout bounds connect + request + headers; the caller owns any idle bound on the body.

async fn dispatch( &self, req: &OutboundRequest, ) -> Result<Response<Incoming>, OutboundError>

Builds and dispatches the outbound request, yielding the response with its body still unread. Shared by request and request_streaming so the two can never drift in connector, TLS or header handling.

fn identity_client( &self, identity: &Arc<UpstreamTls>, ) -> Result<Client<HttpsConnector<HttpConnector>, Full<Bytes>>, OutboundError>

Returns the pooled client for identity, building it on first use. ALPN advertises h1+h2 like the default client (hyper-rustls sets the protocols on the config in enable_http1/enable_http2).

Trait Implementations

impl Default for OutboundClient

fn default() -> Self

Returns the “default value” for a type.