Struct Queue 

pub struct Queue { /* private fields */ }

A celerix Queue handle.

Wraps worker::Queue and provides a clean dispatch() method for jobs. Injected automatically as an axum Extension<Queue> by #[celerix::main].

Implementations

impl Queue

pub fn new(env: Env) -> Queue

Create a new Queue handle from a worker Env.

pub fn dispatch<'a, T>( &'a self, job: T, ) -> SendFuture<impl Future<Output = Result<(), Error>> + 'a>

where T: Job + Serialize + 'a,

Dispatch a job to its queue.

The queue binding is resolved automatically from the job’s queue_binding() (prefixed with the project name).

Returns a Send future so no #[celerix::send] is needed on handlers.

pub fn raw(&self, binding: &str) -> Result<Queue, Error>

Get a raw worker::Queue handle by binding name.

The binding name is auto-prefixed with the project name.

pub fn env(&self) -> &Env

Get the underlying worker Env.

Trait Implementations

impl Clone for Queue

fn clone(&self) -> Queue

Returns a duplicate of the value.

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

Performs copy-assignment from source.