Struct ProxyRouteFailureCacheConnector 

pub struct ProxyRouteFailureCacheConnector<S> { /* private fields */ }

Available on crate feature net only.

Connector wrapper that applies a shared ProxyRouteFailureCache.

This service reads only a singular selected ProxyRoute. Place it inside a connection pool so an existing pooled connection is considered before a new connection is suppressed by the negative cache.

Transport Unavailable, Timeout, Rejected, Protocol, and Other failures are cached. A success or non-cacheable remote failure clears existing backoff state so the next request can try the route again. Local failures provide no evidence about the proxy and leave its backoff unchanged, as do failures marked with ConnectionPolicyScope::Request. Direct and plural routes are ignored.

Implementations

impl<S> ProxyRouteFailureCacheConnector<S>

pub const fn new( inner: S, cache: ProxyRouteFailureCache, ) -> ProxyRouteFailureCacheConnector<S>

Wrap a connector with a shared proxy route failure cache.

pub const fn cache(&self) -> &ProxyRouteFailureCache

Return the configured cache.

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 ProxyRouteFailureCacheConnector<S>

where S: Clone,

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

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<S> Debug for ProxyRouteFailureCacheConnector<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 ProxyRouteFailureCacheConnector<S>

where S: ConnectorService<Input>, Input: AuthorityInputExt + ConnectorTransportProtocolInputExt + ProtocolInputExt + 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<<ProxyRouteFailureCacheConnector<S> as Service<Input>>::Output, <ProxyRouteFailureCacheConnector<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.