Struct UpstreamProxy 

pub struct UpstreamProxy { /* private fields */ }

Proxy that receives iroh streams and forwards them to origin servers.

The upstream proxy is the server-side component that accepts connections from downstream proxies over iroh and forwards requests to actual TCP origin servers.

Protocol Support

• CONNECT tunnels: Establishes TCP connections to the requested authority and bidirectionally forwards data.
• Absolute-form requests: Forwards HTTP requests to origin servers using reqwest, with hop-by-hop header filtering per RFC 9110.

Authorization

All requests pass through an AuthHandler before processing. Unauthorized requests receive a 403 Forbidden response.

Usage

Implements ProtocolHandler for use with iroh’s Router:

let proxy = UpstreamProxy::new(AcceptAll)?;
let router = Router::builder(endpoint)
    .accept(ALPN, proxy)
    .spawn();

Implementations

impl UpstreamProxy

pub fn new(auth: impl AuthHandler + 'static) -> Result<Self>

Creates a new upstream proxy with the provided authorization handler.

pub fn metrics(&self) -> Arc<UpstreamMetrics>

Returns the metrics tracker for this upstream proxy.

pub fn on_shutdown(&self) -> impl Future<Output = ()> + Send + 'static + use<>

Returns a future that resolves when this upstream proxy begins shutting down.

Trait Implementations

impl Debug for UpstreamProxy

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

Formats the value using the given formatter.

impl ProtocolHandler for UpstreamProxy

async fn accept(&self, connection: Connection) -> Result<(), AcceptError>

Handle an incoming connection.

async fn shutdown(&self)

Called when the router shuts down.

fn on_accepting( &self, accepting: Accepting, ) -> impl Future<Output = Result<Connection, AcceptError>> + Send

Optional interception point to handle the Accepting state.