Struct DbJob 

pub struct DbJob { /* private fields */ }

DbJob represents a job as stored in the database.

It contains all the fields from the database table but doesn’t include the task identifier string, which is provided separately when constructing a Job instance for use in the worker system.

Implementations

impl DbJob

pub fn id(&self) -> &i64

Unique identifier for this job

pub fn job_queue_id(&self) -> &Option<i32>

Foreign key to job_queues table if this job is part of a queue

pub fn payload(&self) -> &Value

The JSON payload/data associated with this job

pub fn priority(&self) -> &i16

Priority level (lower number means higher priority)

pub fn run_at(&self) -> &DateTime<Utc>

When the job is scheduled to run

pub fn attempts(&self) -> &i16

How many times this job has been attempted Attempts started, including the current execution (1 on its first run).

pub fn max_attempts(&self) -> &i16

Maximum number of retry attempts before considering the job permanently failed

pub fn last_error(&self) -> &Option<String>

Error message from the last failed attempt

pub fn created_at(&self) -> &DateTime<Utc>

When the job was created

pub fn updated_at(&self) -> &DateTime<Utc>

When the job was last updated

pub fn key(&self) -> &Option<String>

Optional unique key for identifying/updating this job from user code

pub fn revision(&self) -> &i32

Counter tracking the number of revisions/updates to this job

pub fn locked_at(&self) -> &Option<DateTime<Utc>>

When the job was locked for processing

pub fn locked_by(&self) -> &Option<String>

Worker ID that has locked this job

pub fn flags(&self) -> &Option<Value>

Optional JSON flags to control job processing behavior

pub fn task_id(&self) -> &i32

Foreign key to the tasks table identifying the task type

impl DbJob

pub fn from_data(data: DbJobData) -> DbJob

pub fn into_data(self) -> DbJobData

pub fn new( id: i64, job_queue_id: Option<i32>, payload: Value, priority: i16, run_at: DateTime<Utc>, attempts: i16, max_attempts: i16, last_error: Option<String>, created_at: DateTime<Utc>, updated_at: DateTime<Utc>, key: Option<String>, revision: i32, locked_at: Option<DateTime<Utc>>, locked_by: Option<String>, flags: Option<Value>, task_id: i32, ) -> DbJob

Trait Implementations

impl Clone for DbJob

fn clone(&self) -> DbJob

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DbJob

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

Formats the value using the given formatter.

impl Eq for DbJob

impl From<Job> for DbJob

Conversion from Job to DbJob, dropping the task_identifier field

fn from(job: Job) -> DbJob

Converts to this type from the input type.

impl<'a, R> FromRow<'a, R> for DbJob

where R: Row, &'a str: ColumnIndex<R>, i64: Decode<'a, <R as Row>::Database> + Type<<R as Row>::Database>, Option<i32>: Decode<'a, <R as Row>::Database> + Type<<R as Row>::Database>, Value: Decode<'a, <R as Row>::Database> + Type<<R as Row>::Database>, i16: Decode<'a, <R as Row>::Database> + Type<<R as Row>::Database>, DateTime<Utc>: Decode<'a, <R as Row>::Database> + Type<<R as Row>::Database>, Option<String>: Decode<'a, <R as Row>::Database> + Type<<R as Row>::Database>, i32: Decode<'a, <R as Row>::Database> + Type<<R as Row>::Database>, Option<DateTime<Utc>>: Decode<'a, <R as Row>::Database> + Type<<R as Row>::Database>, Option<Value>: Decode<'a, <R as Row>::Database> + Type<<R as Row>::Database>,

fn from_row(__row: &'a R) -> Result<DbJob, Error>

impl PartialEq for DbJob

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for DbJob