Struct Worker 

pub struct Worker {
    pub id: u64,
    /* private fields */
}

A worker that runs jobs from the queue.

Fields

id: u64

The worker’s internal ID.

Implementations

impl Worker

pub async fn unregister(self, timeout: Option<Duration>) -> Result<()>

Unregister a worker from the queue. It will still finish any jobs it is currently running, but will no longer take new jobs.

pub fn builder<CONTEXT>( queue: &Queue, context: CONTEXT, ) -> WorkerBuilder<'_, CONTEXT>

where CONTEXT: Send + Sync + Debug + Clone + 'static,

Create a WorkerBuilder to build a new worker.

pub fn counts(&self) -> WorkerCounts

Return some counts about the number of jobs this worker has processed.

Trait Implementations

impl Drop for Worker

fn drop(&mut self)

Executes the destructor for this type.