Struct TooManyRequests 

pub struct TooManyRequests<P>
where
    P: RetryPolicy,
{ /* private fields */ }

A retry policy decorator that continues on ResourceExhausted or TOO_MANY_REQUESTS.

This policy returns RetryResult::Continue when the error is a ResourceExhausted (or TOO_MANY_REQUESTS if received from the HTTP layer). Otherwise it returns the result from the inner retry policy.

Parameters

• P - the inner retry policy.

Implementations

impl<P> TooManyRequests<P>

where P: RetryPolicy,

pub fn new(inner: P) -> Self

Creates a new instance with a custom inner policy.

Example

use google_cloud_gax::retry_policy::Aip194Strict;
use google_cloud_gax::retry_state::RetryState;
let policy = TooManyRequests::new(Aip194Strict);
assert!(policy.on_error(&RetryState::new(true).set_attempt_count(1_u32), too_many()).is_continue());
assert!(policy.on_error(&RetryState::new(true).set_attempt_count(2_u32), permanent()).is_permanent());

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

Trait Implementations

impl<P> Debug for TooManyRequests<P>

where P: RetryPolicy + Debug,

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

Formats the value using the given formatter.

impl<P> RetryPolicy for TooManyRequests<P>

where P: RetryPolicy,