pub struct ClientTimeout<P>where
P: RetryPolicy,{ /* private fields */ }Expand description
A retry policy decorator that continues on client timeouts.
This policy returns RetryResult::Continue when the error is a client-side timeout and the request is idempotent. Otherwise it returns the result from the inner retry policy.
§Parameters
P- the inner retry policy.
Implementations§
Source§impl<P> ClientTimeout<P>where
P: RetryPolicy,
impl<P> ClientTimeout<P>where
P: RetryPolicy,
Sourcepub fn new(inner: P) -> Self
pub fn new(inner: P) -> Self
Decorate an existing retry policy to ignore client-side timeouts.
§Example
use google_cloud_gax::retry_policy::Aip194Strict;
use google_cloud_gax::retry_state::RetryState;
let policy = ClientTimeout::new(Aip194Strict);
assert!(policy.on_error(&RetryState::new(true).set_attempt_count(1_u32), timeout()).is_continue());
assert!(policy.on_error(&RetryState::new(true).set_attempt_count(2_u32), permanent()).is_permanent());
use google_cloud_gax::error::Error;
fn timeout() -> Error {
}
fn permanent() -> Error {
}Trait Implementations§
Source§impl<P> Debug for ClientTimeout<P>where
P: RetryPolicy + Debug,
impl<P> Debug for ClientTimeout<P>where
P: RetryPolicy + Debug,
impl<P> RetryPolicy for ClientTimeout<P>where
P: RetryPolicy,
Auto Trait Implementations§
impl<P> Freeze for ClientTimeout<P>where
P: Freeze,
impl<P> RefUnwindSafe for ClientTimeout<P>where
P: RefUnwindSafe,
impl<P> Send for ClientTimeout<P>
impl<P> Sync for ClientTimeout<P>
impl<P> Unpin for ClientTimeout<P>where
P: Unpin,
impl<P> UnsafeUnpin for ClientTimeout<P>where
P: UnsafeUnpin,
impl<P> UnwindSafe for ClientTimeout<P>where
P: UnwindSafe,
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
Source§fn in_current_span(self) -> Instrumented<Self> ⓘ
fn in_current_span(self) -> Instrumented<Self> ⓘ
Source§impl<T> RetryPolicyExt for Twhere
T: RetryPolicy,
impl<T> RetryPolicyExt for Twhere
T: RetryPolicy,
Source§fn with_time_limit(self, maximum_duration: Duration) -> LimitedElapsedTime<Self>
fn with_time_limit(self, maximum_duration: Duration) -> LimitedElapsedTime<Self>
Decorate a RetryPolicy to limit the total elapsed time in the retry loop. Read more
Source§fn with_attempt_limit(self, maximum_attempts: u32) -> LimitedAttemptCount<Self>
fn with_attempt_limit(self, maximum_attempts: u32) -> LimitedAttemptCount<Self>
Decorate a RetryPolicy to limit the number of retry attempts. Read more
Source§fn continue_on_too_many_requests(self) -> TooManyRequests<Self>
fn continue_on_too_many_requests(self) -> TooManyRequests<Self>
Decorate a RetryPolicy to continue on certain status codes. Read more
Source§fn continue_on_client_timeout(self) -> ClientTimeout<Self>
fn continue_on_client_timeout(self) -> ClientTimeout<Self>
Decorate a RetryPolicy to continue on client-side timeouts. Read more