Struct Job 

pub struct Job {

    pub id: JobId,
    pub job_type: String,
    pub data: JobData,
    pub priority: JobPriority,
    pub status: JobStatus,
    pub attempts: u32,
    pub max_attempts: u32,
    pub queue: String,
    pub created_at: DateTime<Utc>,
    pub scheduled_at: Option<DateTime<Utc>>,
    pub started_at: Option<DateTime<Utc>>,
    pub completed_at: Option<DateTime<Utc>>,
    pub metadata: HashMap<String, String>,
}

A job to be processed.

Fields

id: JobId

Unique job identifier

job_type: String

Job type/name

data: JobData

Job payload data

priority: JobPriority

Job priority

status: JobStatus

Job status

attempts: u32

Number of attempts

max_attempts: u32

Maximum number of retry attempts

queue: String

Queue name

created_at: DateTime<Utc>

When the job was created

scheduled_at: Option<DateTime<Utc>>

When the job should be processed (for delayed jobs)

started_at: Option<DateTime<Utc>>

When the job was started

completed_at: Option<DateTime<Utc>>

When the job completed/failed

metadata: HashMap<String, String>

Job metadata

Implementations

impl Job

pub fn new( queue: impl Into<String>, job_type: impl Into<String>, data: JobData, ) -> Self

Create a new job.

pub fn with_priority(self, priority: JobPriority) -> Self

Set job priority.

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

Set max retry attempts.

pub fn schedule_at(self, time: DateTime<Utc>) -> Self

Schedule the job for later.

pub fn schedule_after(self, duration: Duration) -> Self

Schedule the job after a delay.

pub fn with_metadata( self, key: impl Into<String>, value: impl Into<String>, ) -> Self

Add metadata.

pub fn is_ready(&self) -> bool

Check if the job is ready to be processed.

pub fn can_retry(&self) -> bool

Check if the job can be retried.

pub fn start_processing(&mut self)

Mark job as processing.

pub fn complete(&mut self)

Mark job as completed.

pub fn fail(&mut self, error: String)

Mark job as failed.

pub fn update_progress(&mut self, progress: u8, message: Option<String>)

Update job progress.

pub fn backoff_delay(&self) -> Duration

Calculate backoff delay for retry.

Trait Implementations

impl Clone for Job

fn clone(&self) -> Job

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Job

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Job

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for Job

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.