Struct JobRow 

pub struct JobRow {
    pub id: String,
    pub queue: String,
    pub name: String,
    pub payload: String,
    pub attempts: i64,
    pub max_attempts: i64,
    pub available_at: DateTime<Utc>,
    pub reserved_at: Option<DateTime<Utc>>,
    pub reserved_until: Option<DateTime<Utc>>,
    pub created_at: DateTime<Utc>,
    pub unique_key: Option<String>,
}

A queued job, as a row.

Fields

id: String

The queued job’s id.

queue: String

Which queue it is on.

name: String

The job’s registered name.

payload: String

Its serialised body, as JSON text.

attempts: i64

How many times it has been attempted.

max_attempts: i64

How many attempts it gets.

available_at: DateTime<Utc>

The earliest it may run.

reserved_at: Option<DateTime<Utc>>

When a worker claimed it, or NULL if it is free.

reserved_until: Option<DateTime<Utc>>

When the current reservation lapses.

created_at: DateTime<Utc>

When it was enqueued.

unique_key: Option<String>

The uniqueness lock this job holds, if it declared a unique_id.

A column rather than something folded into the payload, because the worker needs it to release the lock and reading it should not mean deserialising the job.

Trait Implementations

impl Clone for JobRow

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for JobRow

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

Formats the value using the given formatter.

impl Entity for JobRow

fn table() -> &'static str

The table name.

fn columns() -> &'static [ColumnSpec]

Column metadata, in declaration order. Drives both DDL generation and the column list of generated INSERTs.

fn primary_key() -> &'static str

The primary-key column name. Used by find_by_pk / update / delete_by_pk.

fn indexes() -> &'static [IndexSpec]

Secondary indexes (single-column and composite, unique or not), emitted as separate CREATE INDEX statements by crate::schema. Defaults to none.

fn foreign_keys() -> &'static [ForeignKeySpec]

Foreign-key constraints, emitted inline in the CREATE TABLE. These enforce referential integrity within one database; they are not ORM relationships (no navigation is generated). Defaults to none.

fn shard_columns() -> &'static [&'static str]

Columns whose values are the shard key — a shard-encoded id (#[orm(shard_key)]), the “user id by proxy”. When a query constrains one of these, the repo layer routes the operation to that id’s shard.

fn from_row(row: &dyn Row) -> Result<Self, Error>

Decode one row into Self. Generated to read each field through its FromColumn impl.

fn insert_values(&self) -> Vec<(&'static str, Value)>

(column, value) pairs for an INSERT. Auto-increment primary keys are omitted so the database assigns them.

fn update_values(&self) -> Vec<(&'static str, Value)>

(column, value) pairs for an UPDATE — every column except the primary key.

fn pk_value(&self) -> Value

This instance’s primary-key value, for WHERE pk = ?.

fn value_of(&self, column: &str) -> Option<Value>

One column’s value by name, or None if the entity has no such column.

impl Model for JobRow

fn model_name() -> &'static str

The model’s name, for error messages — "Post".

fn route_key_name() -> &'static str

The column route-model binding looks a member up by.

impl PartialEq for JobRow

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for JobRow