Struct ProxyRoutesConnector 

#[non_exhaustive]
pub struct ProxyRoutesConnector<S> { /* private fields */ }

Available on crate feature net only.

Try ordered proxy routes until a connection is established.

Every route receives an isolated Fork of the original input with the selected ProxyRoute inserted into its extensions. A transport-domain unavailable or timeout failure advances to any next configured route. Explicit rejection, protocol, and other transport failures advance only to another proxy route, never to a direct route. Authentication, invalid-input, and internal failures stop fallback even in the transport domain. Application, local, and unclassified failures also stop immediately because another transport route should not normally change their outcome. This lets proxy-specific failures rotate without turning an intentional rejection into an implicit direct-origin fallback. If multiple attempted routes fail, their contextualized errors are retained in a ProxyRouteConnectError.

Input route decisions use extension insertion order: the most recently inserted ProxyRoute or ProxyRoutes wins. Configure default or authoritative plans on ProxyRoutesLayer, before route-aware middleware, so every consumer observes the same selected route.

Implementations

impl<S> ProxyRoutesConnector<S>

pub const fn new(inner: S) -> ProxyRoutesConnector<S>

Create a connector that reads routes from the input extensions.

pub fn with_timeout(self, timeout: Duration) -> ProxyRoutesConnector<S>

Limit the complete ordered-route operation to timeout.

This is distinct from a timeout applied to the inner connector: an inner timeout applies to one route and can advance to the next route, while this budget covers every route and stops the operation when it is exhausted. Failures completed before the budget expired remain available through ProxyRouteConnectError.

pub fn set_timeout(&mut self, timeout: Duration) -> &mut ProxyRoutesConnector<S>

Limit the complete ordered-route operation to timeout.

This is distinct from a timeout applied to the inner connector: an inner timeout applies to one route and can advance to the next route, while this budget covers every route and stops the operation when it is exhausted. Failures completed before the budget expired remain available through ProxyRouteConnectError.

pub fn get_ref(&self) -> &S

Gets a reference to the underlying service.

pub fn into_inner(self) -> S

Consumes self, returning the underlying service.

Trait Implementations

impl<S> Clone for ProxyRoutesConnector<S>

where S: Clone,

fn clone(&self) -> ProxyRoutesConnector<S>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<S> Debug for ProxyRoutesConnector<S>

where S: Debug,

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

Formats the value using the given formatter.

impl<S, Input> Service<Input> for ProxyRoutesConnector<S>

where S: ConnectorService<Input>, Input: Fork + ExtensionsRef + Send + 'static,

type Output = EstablishedClientConnection<<S as ConnectorService<Input>>::Connection, Input>

The type of the output returned by the service.

type Error = ConnectionError

The type of error returned by the service.

async fn serve( &self, input: Input, ) -> Result<<ProxyRoutesConnector<S> as Service<Input>>::Output, <ProxyRoutesConnector<S> as Service<Input>>::Error>

Serve an output or an error for the given input

fn boxed(self) -> BoxService<Input, Self::Output, Self::Error>

Box this service to allow for dynamic dispatch.