Trait opendal::layers::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