Trait QueueScheduleRepository

pub trait QueueScheduleRepository: Send + Sync {
    type Error;

    // Required methods
    fn setup<'life0, 'life1, 'async_trait>(
        &'life0 mut self,
        schedules: &'life1 [&'static str],
    ) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn list<'life0, 'async_trait>(
        &'life0 mut self,
    ) -> Pin<Box<dyn Future<Output = Result<Vec<ScheduleStatus>, Self::Error>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
}

A QueueScheduleRepository is used to interact with recurrent scheduled jobs in the job queue.

Required Associated Types

type Error

The error type returned by the repository.

Required Methods

fn setup<'life0, 'life1, 'async_trait>( &'life0 mut self, schedules: &'life1 [&'static str], ) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Setup the list of schedules in the repository

Parameters

• schedules - The list of schedules to setup

Errors

Returns an error if the underlying repository fails.

fn list<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<Vec<ScheduleStatus>, Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

List the schedules in the repository, with the last time they were run

Errors

Returns an error if the underlying repository fails.

Implementations on Foreign Types

impl<R> QueueScheduleRepository for Box<R>

where R: QueueScheduleRepository + ?Sized,

type Error = <R as QueueScheduleRepository>::Error

fn setup<'life0, 'life1, 'async_trait>( &'life0 mut self, schedules: &'life1 [&'static str], ) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn list<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<Vec<ScheduleStatus>, Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Implementors

impl<R, F, E> QueueScheduleRepository for MapErr<R, F>

where R: QueueScheduleRepository, F: FnMut(<R as QueueScheduleRepository>::Error) -> E + Send + Sync,

type Error = E