Struct SidekiqServer

pub struct SidekiqServer<'a> {
    pub namespace: String,
    pub force_quite_timeout: usize,
    /* private fields */
}

Fields

namespace: String

force_quite_timeout: usize

Implementations

impl<'a> SidekiqServer<'a>

pub fn new(redis: &str, concurrency: usize) -> Result<Self>

pub fn new_queue(&mut self, name: &str, weight: usize)

pub fn attach_handler<T: JobHandler + 'a>(&mut self, name: &str, handle: T)

pub fn attach_middleware<T: MiddleWare + 'a>(&mut self, factory: T)

pub fn start(&mut self)