Struct ArchivedJob

pub struct ArchivedJob {
    pub id: JobId,
    pub queue_name: String,
    pub status: JobStatus,
    pub created_at: DateTime<Utc>,
    pub archived_at: DateTime<Utc>,
    pub archival_reason: ArchivalReason,
    pub original_payload_size: Option<usize>,
    pub payload_compressed: bool,
    pub archived_by: Option<String>,
}

Information about an archived job.

This struct represents a job that has been moved to the archive table, containing metadata about the original job and archival information.

Examples

use hammerwork::archive::{ArchivedJob, ArchivalReason};
use hammerwork::{JobId, JobStatus};
use chrono::Utc;
use uuid::Uuid;

let job_id = Uuid::new_v4();
let now = Utc::now();

let archived_job = ArchivedJob {
    id: job_id,
    queue_name: "email_queue".to_string(),
    status: JobStatus::Completed,
    created_at: now,
    archived_at: now,
    archival_reason: ArchivalReason::Automatic,
    original_payload_size: Some(1024),
    payload_compressed: true,
    archived_by: Some("scheduler".to_string()),
};

assert_eq!(archived_job.queue_name, "email_queue");
assert_eq!(archived_job.status, JobStatus::Completed);
assert_eq!(archived_job.archival_reason, ArchivalReason::Automatic);
assert!(archived_job.payload_compressed);

Fields

id: JobId

Unique identifier of the archived job.

queue_name: String

Name of the queue the job belonged to.

status: JobStatus

Original job status before archiving.

created_at: DateTime<Utc>

When the job was created.

archived_at: DateTime<Utc>

When the job was archived.

archival_reason: ArchivalReason

Reason for archiving.

original_payload_size: Option<usize>

Size of the original payload in bytes.

payload_compressed: bool

Whether the payload was compressed.

archived_by: Option<String>

Who or what archived the job.

Trait Implementations

impl Clone for ArchivedJob

fn clone(&self) -> ArchivedJob

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ArchivedJob

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ArchivedJob

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for ArchivedJob

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

where __S: Serializer,

Serialize this value into the given Serde serializer.