Struct LimitedAttemptCount 

pub struct LimitedAttemptCount<P = Aip194Strict>
where
    P: RetryPolicy,
{ /* private fields */ }

A retry policy decorator that limits the number of attempts.

This policy decorates an inner policy and limits the total number of attempts. Note that on_error() is not called before the initial (non-retry) attempt. Therefore, setting the maximum number of attempts to 0 or 1 results in no retry attempts.

The policy passes through the results from the inner policy as long as attempt_count < maximum_attempts. However, once the maximum number of attempts is reached, the policy replaces any Continue result with Exhausted.

Parameters

• P - the inner retry policy.

Implementations

impl LimitedAttemptCount

pub fn new(maximum_attempts: u32) -> Self

Creates a new instance, with the default inner policy.

Example

let policy = LimitedAttemptCount::new(5);

impl<P> LimitedAttemptCount<P>

where P: RetryPolicy,

pub fn custom(inner: P, maximum_attempts: u32) -> Self

Creates a new instance with a custom inner policy.

Example

let policy = LimitedAttemptCount::custom(AlwaysRetry, 2);
assert!(policy.on_error(&RetryState::new(false).set_attempt_count(1_u32), permanent_error()).is_continue());
assert!(policy.on_error(&RetryState::new(false).set_attempt_count(2_u32), permanent_error()).is_exhausted());

use google_cloud_gax::error::{Error, rpc::Code, rpc::Status};
fn permanent_error() -> Error { Error::service(Status::default().set_code(Code::PermissionDenied)) }

Trait Implementations

impl<P> Debug for LimitedAttemptCount<P>

where P: RetryPolicy + Debug,

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

Formats the value using the given formatter.

impl<P> RetryPolicy for LimitedAttemptCount<P>

where P: RetryPolicy,