Struct ResilientClientBuilder 

pub struct ResilientClientBuilder { /* private fields */ }

Builder for ResilientClient.

Implementations

impl ResilientClientBuilder

pub fn max_parallel(self, n: usize) -> Self

Cap concurrent in-flight requests for this client. Default 8.

pub fn retry(self, policy: RetryPolicy) -> Self

pub fn circuit_breaker(self, threshold: usize, cooldown: Duration) -> Self

Open the breaker after threshold consecutive failures; stay open for cooldown (fixed), then allow one half-open probe.

pub fn circuit_breaker_growing( self, threshold: usize, base_cooldown: Duration, max_cooldown: Duration, ) -> Self

Like circuit_breaker, but each failed probe doubles the cooldown up to max_cooldown; a success resets it to base_cooldown.

pub fn default_breaker(self) -> Self

The spec’s default: 5 failures, 5 s doubling to 60 s.

pub fn bearer_auth(self, refresher: AuthRefresher) -> Self

Bearer auth, re-acquired lazily and on 401.

pub fn auth( self, refresher: AuthRefresher, header: impl Into<String>, scheme: impl Into<String>, ) -> Self

Auth with a custom header name and scheme prefix.

pub fn http_client(self, client: Client) -> Self

pub fn rate_limit(self, per_second: f64) -> Self

At most per_second attempts per second, with a burst of per_second.ceil().

pub fn rate_limit_with_burst(self, per_second: f64, burst: usize) -> Self

pub fn observer( self, key: impl Into<Arc<str>>, observer: Arc<dyn TransportObserver>, ) -> Self

Report every attempt, retry and breaker transition under key. See TransportObserver::on_event for what the callback may do.

pub fn build(self) -> ResilientClient

Trait Implementations

impl Default for ResilientClientBuilder

fn default() -> Self

Returns the “default value” for a type.