Struct Job 

pub struct Job {
    pub job_id: String,
    pub task_name: String,
    pub actor_json: Value,
    pub params_json: Value,
    pub priority: i32,
    pub pool: String,
    pub status: JobStatus,
    pub idempotency_key: Option<String>,
    pub created_at: DateTime<Utc>,
    pub signature_hash: u64,
    pub attempt: i32,
}

An enqueued unit of work (one task invocation).

Fields

job_id: String

Unique identifier (UUID).

task_name: String

Task name (must exist in registry).

actor_json: Value

Captured actor (identity) at enqueue time.

params_json: Value

Serialized task parameters.

priority: i32

Priority (lower = higher priority). From task config.

pool: String

Pool name for worker assignment.

status: JobStatus

Current status.

idempotency_key: Option<String>

Optional idempotency key.

created_at: DateTime<Utc>

When the job was enqueued.

signature_hash: u64

Signature hash at enqueue (for validation).

attempt: i32

Attempt number (1-based); incremented on retry.

Implementations

impl Job

pub fn new( task_name: &str, actor_json: Value, params_json: Value, priority: i32, pool: &str, signature_hash: u64, idempotency_key: Option<String>, ) -> Job

Create a new queued job (typically from enqueue).

Trait Implementations

impl Clone for Job

fn clone(&self) -> Job

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Job

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Job

fn deserialize<__D>( __deserializer: __D, ) -> Result<Job, <__D as Deserializer<'de>>::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for Job

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

where __S: Serializer,

Serialize this value into the given Serde serializer.