Struct Processor 

pub struct Processor { /* private fields */ }

Implementations

impl Processor

pub fn new(redis: RedisPool, queues: Vec<String>) -> Self

pub fn with_config(self, config: ProcessorConfig) -> Self

pub async fn fetch(&mut self) -> Result<Option<UnitOfWork>>

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

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

pub fn register<Args: Sync + Send + for<'de> Deserialize<'de> + 'static, W: Worker<Args> + 'static>( &mut self, worker: W, )

pub fn get_cancellation_token(&self) -> CancellationToken

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.