pub trait Config<U, StorageError>: 'static + Send + Sync {
    fn next_interval<'life0, 'async_trait>(
        &'life0 self,
        s: ScheduleInfo
    ) -> Pin<Box<dyn Future<Output = Option<Duration>> + Send + 'async_trait>>
    where
        'life0: 'async_trait,
        Self: 'async_trait
;
fn log_storage_error<'life0, 'async_trait>(
        &'life0 self,
        err: StorageError,
        id: Option<QueueId>
    ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>
    where
        'life0: 'async_trait,
        Self: 'async_trait
;
fn log_found_inflight<'life0, 'async_trait>(
        &'life0 self,
        inflight: QueueId
    ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>
    where
        'life0: 'async_trait,
        Self: 'async_trait
;
fn log_found_pending_cleanup<'life0, 'async_trait>(
        &'life0 self,
        pcm: QueueId
    ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>
    where
        'life0: 'async_trait,
        Self: 'async_trait
;
fn log_queued_mail_vanished<'life0, 'async_trait>(
        &'life0 self,
        id: QueueId
    ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>
    where
        'life0: 'async_trait,
        Self: 'async_trait
;
fn log_inflight_mail_vanished<'life0, 'async_trait>(
        &'life0 self,
        id: QueueId
    ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>
    where
        'life0: 'async_trait,
        Self: 'async_trait
;
fn log_pending_cleanup_mail_vanished<'life0, 'async_trait>(
        &'life0 self,
        id: QueueId
    ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>
    where
        'life0: 'async_trait,
        Self: 'async_trait
;
fn log_too_big_duration<'life0, 'async_trait>(
        &'life0 self,
        id: QueueId,
        too_big: Duration,
        new: Duration
    ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>
    where
        'life0: 'async_trait,
        Self: 'async_trait
; fn found_inflight_check_delay(&self) -> Duration { ... }
fn io_error_next_retry_delay(&self, d: Duration) -> Duration { ... } }

Required methods

Provided methods

Implementors