Struct PooledWorkerBuilder 

pub struct PooledWorkerBuilder<B> { /* private fields */ }

Builder for PooledWorker with sensible defaults.

By default, derives the worker ID from {hostname}-{pid}. Override with worker_id.

Created via PooledWorker::builder.

Implementations

impl<B> PooledWorkerBuilder<B>

where B: PersistentBackend + TaskClaimStore + 'static,

pub fn worker_id(self, id: impl Into<String>) -> Self

Set an explicit worker ID.

If not called, the ID is auto-generated from {hostname}-{pid}.

pub fn claim_ttl(self, ttl: Option<Duration>) -> Self

Set the TTL for task claims (default: 5 minutes).

pub fn batch_size(self, size: NonZeroUsize) -> Self

Set the number of tasks to fetch per poll (default: 1).

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

Set the aging interval for priority-based scheduling (default: 300s).

Panics

Panics if interval is zero.

pub fn tags(self, tags: Vec<String>) -> Self

Set affinity tags for this worker.

When tags are set, the worker only picks up tasks whose tags are a subset of the worker’s tags (or tasks with no tags). When no tags are set (the default), the worker accepts all tasks.

pub fn build(self) -> PooledWorker<B>

Build the PooledWorker.

If no worker_id was set, generates one from {hostname}-{pid}.