Trait Job 

pub trait Job:
    Send
    + Serialize
    + Deserialize {
    // Required method
    fn handle(self: Box<Self>) -> Pin<Box<dyn Future<Output = Result<()>>>>;

    // Provided method
    fn queue_binding(&self) -> &'static str { ... }
}

Trait that every job struct must implement.

Use #[celerix::job] on your impl Job for T block. Jobs are automatically registered via typetag — no manual registration needed. The queue consumer will deserialize and dispatch to the right handler automatically.

Example

#[derive(Serialize, Deserialize)]
struct SendEmail {
    to: String,
    subject: String,
}

#[celerix::job]
impl Job for SendEmail {
    fn handle(self: Box<Self>) -> Pin<Box<dyn Future<Output = worker::Result<()>>>> {
        Box::pin(async move {
            worker::console_log!("Sending email to {}", self.to);
            Ok(())
        })
    }
}

// Dispatch:
SendEmail { to: "a@b.com".into() }.dispatch(&env).await?;

Required Methods

fn handle(self: Box<Self>) -> Pin<Box<dyn Future<Output = Result<()>>>>

Execute the job.

Provided Methods

fn queue_binding(&self) -> &'static str

The queue binding name this job targets. Defaults to “QUEUE” which maps to the auto-generated {PROJECT_NAME}_QUEUE in wrangler.toml. Override this to send to a different queue.

Trait Implementations

impl<'typetag> Serialize for dyn Job + 'typetag

fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error>

where S: Serializer,

Serialize this value into the given Serde serializer.

impl<'typetag> Serialize for dyn Job + Send + 'typetag

fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error>

where S: Serializer,

Serialize this value into the given Serde serializer.

impl<'typetag> Serialize for dyn Job + Send + Sync + 'typetag

fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error>

where S: Serializer,

Serialize this value into the given Serde serializer.

impl<'typetag> Serialize for dyn Job + Sync + 'typetag

fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error>

where S: Serializer,

Serialize this value into the given Serde serializer.

Implementors