Struct Config 

pub struct Config<DT, ET> {
    pub storage: Storage,
    /* private fields */
}

Fields

storage: Storage

Implementations

impl<DT, ET> Config<DT, ET>

pub fn new(storage: &Storage) -> Self

pub fn register_queue<Q>(self) -> Self

where Q: Queue,

pub fn register_queue_with(&mut self, config: QueueConfig)

pub fn register_queue_with_concurrency<Q>(self, concurrency: usize) -> Self

where Q: Queue,

pub fn register_worker<W>(self) -> Self

where W: Worker<Context = DT, Error = ET> + DeserializeOwned + 'static,

pub fn register_cron_worker<W>(self, queue: impl Queue) -> Self

where W: Worker<Context = DT, Error = ET> + DeserializeOwned + 'static,

Register a cron worker with a dynamic queue

pub fn register_worker_with(&mut self, config: WorkerConfig<DT, ET>)

pub fn exit_when_processed(self, processed: u64) -> Self

pub fn with_graceful_shutdown( self, fut: impl Future<Output = Result<(), Error>> + Send + Sync + 'static, ) -> Self

pub fn consume_shutdown_signal( &mut self, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + Sync + 'static>>

pub fn has_registered_queue<Q: Queue>(&self) -> bool

pub fn has_registered_worker<W>(&self) -> bool

where W: Worker<Context = DT, Error = ET>,

pub fn has_registered_cron_worker<W>(&self) -> bool

where W: Worker<Context = DT, Error = ET>,