Struct Job 

pub struct Job { /* private fields */ }

Named handler with optional recurring schedule, queue, and priority.

Implementations

impl Job

pub fn new<F, Fut>(name: impl Into<String>, f: F) -> Self

where F: Fn(Task) -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<(), String>> + Send + 'static,

pub fn queue(self, q: impl Into<String>) -> Self

Named queue for schedule enqueue and default dispatch routing.

pub fn priority(self, p: i32) -> Self

Claim priority within the queue (higher first). Default priority::NORMAL.

pub fn every(self, period: Duration) -> Self

Run approximately every period (slot-based dedup across instances).

pub fn cron(self, expr: impl AsRef<str>) -> Self

Cron expression: 5 fields (min hour day month dow) or 6 (sec min …).

pub fn payload(self, data: Value) -> Self

JSON data field used when the scheduler enqueues this job.