Struct CompareAndRequeueJob 

pub struct CompareAndRequeueJob<'a> {
    pub scope: JobScope,
    pub job_id: Uuid,
    pub expected_status: RequeueableJobStatus,
    pub expected_run_number: i32,
    pub state_policy: JobRequeueStatePolicy,
    pub reason: &'a str,
}

Fields

scope: JobScope

job_id: Uuid

expected_status: RequeueableJobStatus

expected_run_number: i32

state_policy: JobRequeueStatePolicy

reason: &'a str

Implementations

impl<'a> CompareAndRequeueJob<'a>

pub fn from_observed_job( observed: &JobQueueRecord, state_policy: JobRequeueStatePolicy, reason: &'a str, ) -> Result<Self, NonRequeueableJobStatusError>

Builds a compare-and-requeue request from an observed terminal job.

The job’s exact tenant scope, identifier, status, and run number are copied into the request so callers cannot accidentally turn a scoped observation into a wildcard or lose the optimistic-concurrency fence.

Errors

Returns NonRequeueableJobStatusError unless the observation is canceled or dead-lettered. Successful jobs require a separate replay policy and pending or leased jobs are not recovery candidates.

Trait Implementations

impl<'a> Clone for CompareAndRequeueJob<'a>

fn clone(&self) -> CompareAndRequeueJob<'a>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<'a> Debug for CompareAndRequeueJob<'a>

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

Formats the value using the given formatter.