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.

Dyn Compatibility

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

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