Struct JobRecord 

pub struct JobRecord {

    pub id: Uuid,
    pub job_type: String,
    pub input: Value,
    pub output: Option<Value>,
    pub status: JobStatus,
    pub priority: i32,
    pub attempts: i32,
    pub max_attempts: i32,
    pub last_error: Option<String>,
    pub worker_capability: Option<String>,
    pub worker_id: Option<Uuid>,
    pub idempotency_key: Option<String>,
    pub scheduled_at: DateTime<Utc>,
    pub created_at: DateTime<Utc>,
    pub claimed_at: Option<DateTime<Utc>>,
    pub started_at: Option<DateTime<Utc>>,
    pub completed_at: Option<DateTime<Utc>>,
    pub failed_at: Option<DateTime<Utc>>,
    pub last_heartbeat: Option<DateTime<Utc>>,
}

A job record in the database.

Fields

id: Uuid

Unique job ID.

job_type: String

Job type/name.

input: Value

Job input as JSON.

output: Option<Value>

Job output as JSON (if completed).

status: JobStatus

Current status.

priority: i32

Priority level.

attempts: i32

Number of attempts made.

max_attempts: i32

Maximum attempts allowed.

last_error: Option<String>

Last error message.

worker_capability: Option<String>

Required worker capability.

worker_id: Option<Uuid>

Worker ID that claimed the job.

idempotency_key: Option<String>

Idempotency key for deduplication.

scheduled_at: DateTime<Utc>

When the job is scheduled to run.

created_at: DateTime<Utc>

When the job was created.

claimed_at: Option<DateTime<Utc>>

When the job was claimed.

started_at: Option<DateTime<Utc>>

When the job started running.

completed_at: Option<DateTime<Utc>>

When the job completed.

failed_at: Option<DateTime<Utc>>

When the job failed.

last_heartbeat: Option<DateTime<Utc>>

Last heartbeat time.

Implementations

impl JobRecord

pub fn new( job_type: impl Into<String>, input: Value, priority: JobPriority, max_attempts: i32, ) -> Self

Create a new job record.

pub fn with_capability(self, capability: impl Into<String>) -> Self

Set worker capability requirement.

pub fn with_scheduled_at(self, at: DateTime<Utc>) -> Self

Set scheduled time.

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

Set idempotency key.

Trait Implementations

impl Clone for JobRecord

fn clone(&self) -> JobRecord

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for JobRecord

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

Formats the value using the given formatter.