Struct WorkerConnection

pub struct WorkerConnection { /* private fields */ }

The connection to Redis. Required to enqueue and dequeue jobs.

Each WorkerConnection has exactly one actual Redis connection.

Implementations

impl WorkerConnection

pub fn config(&self) -> &Config

Returns the connections config

pub fn enqueue_to( &self, iden: QueueIdentifier, name: JobName, args: &Args, retry_count: RetryCount, ) -> RobinResult<()>

Put a job into the queue.

This method will enqueue the job regardless of what the retry_count is. Not reenqueueing jobs that failed too much is handled at another level.

pub fn retry( &self, name: JobName, args: &Args, retry_count: RetryCount, ) -> RobinResult<()>

Put the job into the retry queue.

pub fn dequeue_from<'a>( &'a self, iden: QueueIdentifier, timeout: DequeueTimeout, ) -> Result<(Box<dyn Job + Send>, String, RetryCount), NoJobDequeued>

Pull the first job out of the queue.

pub fn delete_all(&self) -> RobinResult<()>

Delete all jobs from all queues

pub fn size(&self, iden: QueueIdentifier) -> RobinResult<usize>

The number of jobs in the queue

pub fn main_queue_size(&self) -> RobinResult<usize>

The number of jobs in the main queue

pub fn retry_queue_size(&self) -> RobinResult<usize>

The number of jobs in the retry queue

pub fn is_queue_empty(&self, iden: QueueIdentifier) -> RobinResult<bool>

true if there are 0 jobs in the queue, false otherwise

Trait Implementations

impl Debug for WorkerConnection

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.