Struct opendal::layers::RetryLayer

pub struct RetryLayer<B: Backoff + Send + Sync + Debug + 'static>(_);

RetryLayer will add retry for OpenDAL.

Examples

use anyhow::Result;
use backon::ExponentialBackoff;
use opendal::layers::RetryLayer;
use opendal::Operator;
use opendal::Scheme;

let _ = Operator::from_env(Scheme::Fs)
    .expect("must init")
    .layer(RetryLayer::new(ExponentialBackoff::default()));

Implementations

impl<B> RetryLayer<B>where
    B: Backoff + Send + Sync + Debug + 'static,

pub fn new(b: B) -> Self

Create a new retry layer.

Examples

use anyhow::Result;
use backon::ExponentialBackoff;
use opendal::layers::RetryLayer;
use opendal::Operator;
use opendal::Scheme;

let _ = Operator::from_env(Scheme::Fs)
    .expect("must init")
    .layer(RetryLayer::new(ExponentialBackoff::default()));

Trait Implementations

impl<B> Layer for RetryLayer<B>where
    B: Backoff + Send + Sync + Debug + 'static,

fn layer(&self, inner: Arc<dyn Accessor>) -> Arc<dyn Accessor>

Intercept the operations on the underlying storage.