Struct Worker 

pub struct Worker { /* private fields */ }

Pulls jobs off a queue and runs them.

Implementations

impl Worker

pub fn with_locks(self, locks: LockManager) -> Self

Enforce unique_id releases with locks.

The same manager the dispatching side uses, or the release will not find the key. Worker::from_manager wires it for you.

pub fn new( queue: Arc<dyn Queue>, registry: Arc<JobRegistry>, container: Arc<Container>, ) -> Self

A worker serving queue, running the jobs registry knows.

pub fn with_events(self, events: Arc<Dispatcher>) -> Self

Fire lifecycle events through events.

pub fn with_options(self, options: WorkerOptions) -> Self

Configure the loop.

pub fn stop(&self)

Ask the loop to stop after the job in flight.

pub fn is_stopping(&self) -> bool

Whether a stop has been requested.

pub async fn run_next(&self) -> Result<Outcome>

Reserve and run one job from the first queue that has one.

pub async fn run(&self) -> Result<WorkerStats>

Run until stopped, drained, or the job limit is reached.

Between jobs the worker flushes the container’s scoped bindings, so one job cannot leak per-request-shaped state into the next. That is the long-running-process hazard a per-request framework never has to think about.

Trait Implementations

impl Debug for Worker

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

Formats the value using the given formatter.