Struct Processor 

pub struct Processor { /* private fields */ }

Implementations

impl Processor

pub fn new( redis: Pool<RedisConnectionManager>, queues: Vec<String>, ) -> Processor

pub async fn process_one(&mut self) -> Result<(), Error>

pub async fn process_one_tick_once(&mut self) -> Result<WorkFetcher, Error>

pub fn register<Args, W>(&mut self, worker: W)

where Args: Sync + Send + for<'de> Deserialize<'de> + 'static, W: Worker<Args> + 'static,

pub async fn run(self)

Takes self to consume the processor. This is for life-cycle management, not memory safety because you can clone processor pretty easily.

pub async fn using<M>(&mut self, middleware: M)

where M: ServerMiddleware + Send + Sync + 'static,

Trait Implementations

impl Clone for Processor

fn clone(&self) -> Processor

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.