Struct Worker 

pub struct Worker { /* private fields */ }

One worker. Cloning is cheap and gives a second worker on the same queue.

Implementations

impl Worker

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

pub fn reporting_to(self, store: Arc<dyn ProgressStore>) -> Self

Give jobs somewhere to report progress. The web process reads the same store, so it must be one both can reach — the database one, unless the worker runs inside the web process.

pub fn on_queue(self, queue: impl Into<String>) -> Self

pub fn poll_interval(self, interval: Duration) -> Self

pub fn max_jobs(self, count: u64) -> Self

Stop after count attempts, whatever the shutdown signal says.

pub fn backoff_cap(self, cap: Duration) -> Self

pub fn options(&self) -> &WorkerOptions

pub async fn run(&self, shutdown: Shutdown) -> Result<WorkerStats>

Work until shutdown is signalled or max_jobs is reached.

The shutdown check is at the top of the loop and nowhere else. That is the entire graceful-shutdown guarantee: a job already reserved is always run to completion, because there is no point at which the loop can abandon one.

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

Reserve and run at most one job. None when the queue had nothing ready.

pub async fn process(&self, reserved: ReservedJob) -> Result<Outcome>

Run one reserved job and settle its fate.

Trait Implementations

impl Clone for Worker

fn clone(&self) -> Worker

Returns a duplicate of the value.

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

Performs copy-assignment from source.