Struct ResilientClientBuilder 

pub struct ResilientClientBuilder { /* private fields */ }

Builder for ResilientClient.

Implementations

impl ResilientClientBuilder

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

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

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

Retry policy for ResilientClient::execute. Calls made through execute_with carry their own CallPolicy.

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

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, ) -> ResilientClientBuilder

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) -> ResilientClientBuilder

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

pub fn bearer_auth( self, refresher: Arc<dyn Fn() -> Pin<Box<dyn Future<Output = Result<String, Error>> + Send>> + Send + Sync>, ) -> ResilientClientBuilder

Bearer auth, re-acquired lazily and on 401.

pub fn auth( self, refresher: Arc<dyn Fn() -> Pin<Box<dyn Future<Output = Result<String, Error>> + Send>> + Send + Sync>, header: impl Into<String>, scheme: impl Into<String>, ) -> ResilientClientBuilder

Auth with a custom header name and scheme prefix.

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

Send requests with client instead of a default one. The client keeps its own settings; request_timeout does not apply to it.

pub fn request_timeout(self, timeout: Duration) -> ResilientClientBuilder

Give up on a single request after timeout (default 30 s). It covers connecting, sending and reading the response, and a timed-out attempt is a retryable transport failure.

Applies only to the default client this crate builds; a client passed to http_client keeps its own timeout.

pub fn no_request_timeout(self) -> ResilientClientBuilder

Never time a request out. Applies only to the default client, like request_timeout.

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

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, ) -> ResilientClientBuilder

Like rate_limit with an explicit burst size.

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

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

pub fn build(self) -> ResilientClient

Finish the client. No network or proxy work happens here: a default HTTP client is built on the first request. If that build keeps failing, every attempt fails with a retryable ErrorKind::Transport, so an essential() call keeps retrying.

Trait Implementations

impl Default for ResilientClientBuilder

fn default() -> ResilientClientBuilder

Returns the “default value” for a type.