Trait RetryInterceptor

pub trait RetryInterceptor:
    Send
    + Sync
    + 'static {
    // Required method
    fn intercept(&self, err: &Error, dur: Duration);
}

RetryInterceptor is used to intercept while retry happened.

Required Methods

fn intercept(&self, err: &Error, dur: Duration)

Everytime RetryLayer is retrying, this function will be called.

Timing

just before the retry sleep.

Inputs

• err: The error that caused the current retry.
• dur: The duration that will sleep before next retry.

Notes

The intercept must be quick and non-blocking. No heavy IO is allowed. Otherwise, the retry will be blocked.

Implementors

impl<F> RetryInterceptor for F

where F: Fn(&Error, Duration) + Send + Sync + 'static,