pub trait MakeJobQueue: Send + Sync {
    type Queue: JobQueue;
    type Err: Error + Send;

    fn make_job_queue<'life0, 'life1, 'async_trait>(
        &'life0 self,
        name: &'life1 str,
        url: Url
    ) -> Pin<Box<dyn Future<Output = Result<Self::Queue, Self::Err>> + Send + 'async_trait>>
    where
        'life0: 'async_trait,
        'life1: 'async_trait,
        Self: 'async_trait
; }
Expand description

The queue factory trait that takes care of creating queues

Required Associated Types

The type of job queue returned by this factory

The type of error that can occur when creating a job queue

Required Methods

Create a new job queue using this factory

Implementors