Struct ProcessedJob 

pub struct ProcessedJob {
    pub id: i32,
    pub job_id: i32,
    pub return_value: String,
    pub payload: String,
    pub attempts: i32,
    pub processed_at: NaiveDateTime,
}

Represents a successfully processed job record in the database.

This corresponds to the processed_jobs table, which stores details of jobs that have been completed. It can be used for auditing, logging, or debugging purposes after a job is removed from the active jobs table.

Fields

• id: Primary key (database-generated).
• job_id: The original id from the jobs table.
• return_value: Data returned when the job was processed (e.g., a result string).
• payload: The job’s original payload (e.g., parameters).
• attempts: The number of attempts made to run this job before it was completed.
• processed_at: The timestamp indicating when the job was processed.

Fields

id: i32

job_id: i32

return_value: String

payload: String

attempts: i32

processed_at: NaiveDateTime

Implementations

impl ProcessedJob

pub fn create(job: &Job, _return_value: String) -> Result<(), Error>

Creates a new record in the processed_jobs table based on a completed Job.

This method:

1. Constructs a NewProcessedJob from the provided Job data and a user-provided return value string.
2. Acquires a database connection via DB::get_conn.
3. Inserts the NewProcessedJob into the processed_jobs table.

Parameters

• job: The Job that has been successfully completed.
• _return_value: A string describing the outcome of the job (result data or message).

Returns

• Ok(()) if the record was inserted successfully.
• Err(diesel::result::Error) if there is a connection or insertion failure.

Example

// Suppose `some_job` is an instance of a `Job` that has completed successfully.
let some_job = Job {
    id: 1,
    payload: "example payload".to_string(),
    status: "completed".to_string(),
    attempts: 1,
    available_at: chrono::Local::now().naive_local(),
    created_at: chrono::Local::now().naive_local(),
    updated_at: chrono::Local::now().naive_local(),
};
 
let return_msg = "Processed successfully".to_string();

match ProcessedJob::create(some_job, return_msg) {
    Ok(_) => println!("Successfully inserted processed job record."),
    Err(e) => eprintln!("Failed to create processed job record: {:?}", e),
}

Trait Implementations

impl Debug for ProcessedJob

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ProcessedJob

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl<'insert> Insertable<table> for &'insert ProcessedJob

type Values = <(Option<Grouped<Eq<id, <&'insert i32 as AsExpression<<id as Expression>::SqlType>>::Expression>>>, Option<Grouped<Eq<job_id, <&'insert i32 as AsExpression<<job_id as Expression>::SqlType>>::Expression>>>, Option<Grouped<Eq<return_value, <&'insert String as AsExpression<<return_value as Expression>::SqlType>>::Expression>>>, Option<Grouped<Eq<payload, <&'insert String as AsExpression<<payload as Expression>::SqlType>>::Expression>>>, Option<Grouped<Eq<attempts, <&'insert i32 as AsExpression<<attempts as Expression>::SqlType>>::Expression>>>, Option<Grouped<Eq<processed_at, <&'insert NaiveDateTime as AsExpression<<processed_at as Expression>::SqlType>>::Expression>>>) as Insertable<table>>::Values

The VALUES clause to insert these records

fn values( self, ) -> <(Option<Eq<id, &'insert i32>>, Option<Eq<job_id, &'insert i32>>, Option<Eq<return_value, &'insert String>>, Option<Eq<payload, &'insert String>>, Option<Eq<attempts, &'insert i32>>, Option<Eq<processed_at, &'insert NaiveDateTime>>) as Insertable<table>>::Values

Construct Self::Values

fn insert_into(self, table: T) -> InsertStatement<T, Self::Values>

where T: Table, Self: Sized,

Insert self into a given table.

impl Insertable<table> for ProcessedJob

type Values = <(Option<Grouped<Eq<id, <i32 as AsExpression<<id as Expression>::SqlType>>::Expression>>>, Option<Grouped<Eq<job_id, <i32 as AsExpression<<job_id as Expression>::SqlType>>::Expression>>>, Option<Grouped<Eq<return_value, <String as AsExpression<<return_value as Expression>::SqlType>>::Expression>>>, Option<Grouped<Eq<payload, <String as AsExpression<<payload as Expression>::SqlType>>::Expression>>>, Option<Grouped<Eq<attempts, <i32 as AsExpression<<attempts as Expression>::SqlType>>::Expression>>>, Option<Grouped<Eq<processed_at, <NaiveDateTime as AsExpression<<processed_at as Expression>::SqlType>>::Expression>>>) as Insertable<table>>::Values

The VALUES clause to insert these records

fn values( self, ) -> <(Option<Eq<id, i32>>, Option<Eq<job_id, i32>>, Option<Eq<return_value, String>>, Option<Eq<payload, String>>, Option<Eq<attempts, i32>>, Option<Eq<processed_at, NaiveDateTime>>) as Insertable<table>>::Values

Construct Self::Values

fn insert_into(self, table: T) -> InsertStatement<T, Self::Values>

where T: Table, Self: Sized,

Insert self into a given table.

impl<__DB: Backend, __ST0, __ST1, __ST2, __ST3, __ST4, __ST5> Queryable<(__ST0, __ST1, __ST2, __ST3, __ST4, __ST5), __DB> for ProcessedJob

where (i32, i32, String, String, i32, NaiveDateTime): FromStaticSqlRow<(__ST0, __ST1, __ST2, __ST3, __ST4, __ST5), __DB>,

type Row = (i32, i32, String, String, i32, NaiveDateTime)

The Rust type you’d like to map from.

fn build(row: (i32, i32, String, String, i32, NaiveDateTime)) -> Result<Self>

Construct an instance of this type

impl Serialize for ProcessedJob

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl UndecoratedInsertRecord<table> for ProcessedJob