Struct ResilientClient 

pub struct ResilientClient { /* private fields */ }

A cheap-to-clone resilient HTTP client. Build via ResilientClient::builder.

Implementations

impl ResilientClient

pub fn builder() -> ResilientClientBuilder

pub async fn execute<F>(&self, build: F) -> Result<Response, ClientError>

where F: Fn(&Client) -> RequestBuilder,

Execute a request with the client’s default policies (bounded retry, fail fast on an open breaker). build is called once per attempt.

pub async fn execute_with<F>( &self, policy: &CallPolicy, build: F, ) -> Result<Response, ClientError>

where F: Fn(&Client) -> RequestBuilder,

Execute a request under policy. Returns the first 2xx response, or the last attempt’s failure. Dropping the returned future cancels the in-flight request and any pending back-off.

pub fn in_flight(&self) -> usize

Requests in flight right now — sent, not yet answered. Waiting for a breaker cooldown, a rate-limit token, a permit or a retry back-off does not count.

pub fn peak_in_flight(&self) -> usize

Highest number of simultaneously in-flight requests observed.

pub fn breaker_state(&self) -> Option<BreakerState>

What the circuit breaker is doing right now, for consumers that poll rather than follow TransportEvents. None when this client has no breaker configured.

pub fn key(&self) -> Option<&str>

The datasource key this client reports under, when it has an observer.

pub fn report(&self, event: TransportEvent)

Emit an event on behalf of the caller (RowsPulled, WritePushed).

Trait Implementations

impl Clone for ResilientClient

fn clone(&self) -> ResilientClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ResilientClient

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

Formats the value using the given formatter.