Struct Job 

pub struct Job {
    pub id: Uuid,
    pub fingerprint: Option<String>,
    pub unique_key: Option<String>,
    pub queue: String,
    pub job_data: Value,
    pub status: String,
    pub created_at: DateTime<Utc>,
    pub run_at: Option<DateTime<Utc>>,
    pub updated_at: Option<DateTime<Utc>>,
    pub attempt: i32,
    pub max_attempts: i32,
    /* private fields */
}

Represents a job processed/processing by the queue.

Fields

id: Uuid

Job ID

fingerprint: Option<String>

Fingerprint, made as a soft key for deduplication purposes or cancelling. Does not violate any database constraints.

unique_key: Option<String>

Unique key - database constraint on unique_key jobs in pending and running states. Repeated inserts with the same unique_key will be rejected by the database.

queue: String

Name of the queue job belongs to.

job_data: Value

Payload - serde_json::Value,

status: String

Current status of the job in string form

created_at: DateTime<Utc>

Timestamp when the job was created.

run_at: Option<DateTime<Utc>>

Timestamp when the job is scheduled to run.

updated_at: Option<DateTime<Utc>>

Timestamp when the job was last updated (for use by heartbeat)

attempt: i32

Attempt count of the job

max_attempts: i32

Maximum number of attempts for the job

Implementations

impl Job

pub fn new<T: Serialize + DeserializeOwned>( queue: &'static str, job_data: T, ) -> Self

Create a new Job instance with the given queue name and job payload.

pub fn with_unique_key(self, unique_key: impl Into<String>) -> Self

Builder method: sets Job::unique_key

pub fn with_run_at(self, run_at: DateTime<Utc>) -> Self

Builder method: sets Job::run_at

pub fn with_max_attempts(self, max_attempts: i32) -> Self

Builder method: sets Job::max_attempts

pub fn with_fingerprint(self, fingerprint: impl Into<String>) -> Self

Builder method: sets Job::fingerprint

Trait Implementations

impl Debug for Job

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

Formats the value using the given formatter.

impl Default for Job

fn default() -> Self

Returns the “default value” for a type.