Struct WorkerBuilder 

pub struct WorkerBuilder { /* private fields */ }

Staged builder for an immutable queue worker.

Task registration is a local process capability declaration. PostgreSQL remains authoritative for task state and only returns claims whose names match the capabilities frozen into the worker. Producers do not need this registry.

The default concurrency is one and the default finite lease duration is 120 seconds.

Implementations

impl WorkerBuilder

pub fn lease_duration(self, lease_duration: Duration) -> Self

Set the finite lease duration for this worker.

PostgreSQL remains authoritative for lease validity and renewal. The duration only controls how much lease time each successful supervision call requests.

pub fn concurrency(self, concurrency: usize) -> Self

Set the maximum number of task attempts this worker executes concurrently.

Claims are limited to currently available execution capacity, so the worker never owns more runs than it can begin executing immediately.

pub fn task<Input, Output>( self, task: Task<Input, Output>, handler: impl TaskHandler<Input, Output>, ) -> Self

where Input: DeserializeOwned + Send + 'static, Output: Serialize + Send + 'static,

Register one typed task with an in-process async handler.

This is the normal registration path. The same Task value is shared by producers and workers, so the persisted name and Rust input/output types stay together without a marker type or runtime registry.

pub fn task_executor<Input, Output>( self, task: Task<Input, Output>, executor: impl TaskExecutor<Input, Output>, ) -> Self

where Input: DeserializeOwned + Send + 'static, Output: Serialize + Send + 'static,

Register one typed task using a reusable TaskExecutor.

The executor may run the attempt in-process or provision a process, container, sandbox, VM, Kubernetes Job, or another execution substrate. This changes only where one attempt computes; durability and supervision still use the same worker path.

pub fn build(self) -> Result<Worker>

Freeze task capabilities and return a runnable worker.

Errors

Returns an error if registration failed or no task capability was declared.

Trait Implementations

impl Debug for WorkerBuilder

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

Formats the value using the given formatter.

Layout

Note: Most layout information is completely unstable and may even differ between compilations. The only exception is types with certain repr(...) attributes. Please see the Rust Reference's “Type Layout” chapter for details on type layout guarantees.

Size: 264 bytes