Struct RetryPolicy 

pub struct RetryPolicy {
    pub max_retries: u32,
    pub initial_backoff: Duration,
    pub max_backoff: Duration,
    pub unhealthy_backoff: Duration,
}

Retry behavior for transient request failures.

Carried by Client as its inner state: construct one and pass it to Client::new / Client::new_with_client.

Fields

max_retries: u32

Retries after the initial attempt. 3 means up to 4 attempts total; 0 disables retrying.

initial_backoff: Duration

Wait before the first retry. Each further retry doubles the wait.

max_backoff: Duration

Upper bound on the wait between attempts.

unhealthy_backoff: Duration

Flat wait between 502 retries while the cluster reports unhealthy on /v0/cluster_healthz: the cluster is likely upgrading or restarting, so a flat pause beats an exponential ramp. Not capped by max_backoff.

Implementations

impl RetryPolicy

pub fn none() -> Self

A policy that never retries.

Trait Implementations

impl ClientHooks<RetryPolicy> for &Client

async fn pre<E>( &self, request: &mut Request, info: &OperationInfo, ) -> Result<(), Error<E>>

Runs prior to the execution of the request. This may be used to modify the request before it is transmitted.

async fn post<E>( &self, result: &Result<Response, Error>, info: &OperationInfo, ) -> Result<(), Error<E>>

Runs after completion of the request.

async fn exec( &self, request: Request, info: &OperationInfo, ) -> Result<Response, Error>

Execute the request. Note that for almost any reasonable implementation this will include code equivalent to this:

impl ClientHooks<RetryPolicy> for Client

Route every request through the retry layer. Overrides the no-op default on &Client via auto-ref specialization (see progenitor_client::ClientHooks).

async fn exec(&self, request: Request, info: &OperationInfo) -> Result<Response>

Execute the request. Note that for almost any reasonable implementation this will include code equivalent to this:

async fn pre<E>( &self, request: &mut Request, info: &OperationInfo, ) -> Result<(), Error<E>>

Runs prior to the execution of the request. This may be used to modify the request before it is transmitted.

async fn post<E>( &self, result: &Result<Response, Error>, info: &OperationInfo, ) -> Result<(), Error<E>>

Runs after completion of the request.

impl ClientInfo<RetryPolicy> for Client

fn api_version() -> &'static str

Get the version of this API.

fn baseurl(&self) -> &str

Get the base URL to which requests are made.

fn client(&self) -> &Client

Get the internal reqwest::Client used to make requests.

fn inner(&self) -> &RetryPolicy

Get the inner value of type T if one is specified.

impl Clone for RetryPolicy

fn clone(&self) -> RetryPolicy

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RetryPolicy

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

Formats the value using the given formatter.

impl Default for RetryPolicy

fn default() -> Self

Returns the “default value” for a type.

impl Eq for RetryPolicy

impl PartialEq for RetryPolicy

fn eq(&self, other: &RetryPolicy) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for RetryPolicy