Struct QueuedJob 

pub struct QueuedJob {
    pub name: String,
    pub payload: Json,
    pub queue: String,
    pub max_tries: u32,
    pub retry_after: Duration,
    pub delay: Duration,
}

A job as it is stored: a name, a payload, and the policy for running it.

Everything past the dispatch call deals in this rather than in a concrete type, which is what keeps the Queue trait dyn-compatible.

Fields

name: String

payload: Json

queue: String

max_tries: u32

retry_after: Duration

delay: Duration

How long after being pushed the job becomes visible to a worker.

Implementations

impl QueuedJob

pub fn new(name: impl Into<String>, payload: Json) -> Self

An envelope built by hand, for a caller that has a name and a payload but no Rust type — a job pushed by another service, say.

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

pub fn with_delay(self, delay: Duration) -> Self

pub fn with_tries(self, tries: u32) -> Self

pub fn with_retry_after(self, retry_after: Duration) -> Self

Trait Implementations

impl Clone for QueuedJob

fn clone(&self) -> QueuedJob

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for QueuedJob

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

Formats the value using the given formatter.

impl PartialEq for QueuedJob

fn eq(&self, other: &QueuedJob) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for QueuedJob