Struct ClientBuilder 

pub struct ClientBuilder { /* private fields */ }

Builder for the Awa worker client.

Implementations

impl ClientBuilder

pub fn new(pool: PgPool) -> Self

pub fn queue(self, name: impl Into<String>, config: QueueConfig) -> Self

Add a queue with its configuration.

pub fn register<T, F, Fut>(self, handler: F) -> Self

where T: JobArgs + DeserializeOwned + Send + Sync + 'static, F: Fn(T, &JobContext) -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<JobResult, JobError>> + Send + Sync + 'static,

Register a typed worker.

The worker handles jobs of type T where T: JobArgs + DeserializeOwned. The handler function receives the deserialized args and job context.

pub fn register_worker(self, worker: impl Worker + 'static) -> Self

Register a raw worker implementation.

pub fn state<T: Any + Send + Sync + Clone>(self, value: T) -> Self

Add shared state accessible via ctx.extract::<T>().

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

Set the heartbeat interval (default: 30s).

pub fn build(self) -> Result<Client, BuildError>

Build the client.