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_concurrency<Q>(self, concurrency: usize) -> Self

where Q: Queue,

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

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

pub fn register_cron_worker<T>(self, schedule: &str, queue: impl Queue) -> Self

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

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>>