Struct JobEnqueueIntent 

pub struct JobEnqueueIntent<'a> { /* private fields */ }

A durable request to enqueue a job after its definition becomes available.

Recording an intent does not read job_definitions and does not create a queue row. Every intent is strictly idempotent; retries must preserve every requested enqueue field.

Implementations

impl<'a> JobEnqueueIntent<'a>

pub fn new( job_type: JobType<'a>, payload: &'a Value, idempotency_key: &'a str, ) -> Self

pub fn with_organization_id(self, organization_id: Uuid) -> Self

pub fn with_priority(self, priority: i32) -> Self

pub fn with_max_attempts(self, max_attempts: i32) -> Self

pub fn with_timeout_seconds(self, timeout_seconds: i32) -> Self

pub fn with_next_run_at(self, next_run_at: DateTime<Utc>) -> Self

pub fn with_stage(self, stage: JobStage) -> Self

pub fn with_execution_resource(self, execution_resource_key: &'a str) -> Self

Trait Implementations

impl<'a> Clone for JobEnqueueIntent<'a>

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

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<'a> Debug for JobEnqueueIntent<'a>

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

Formats the value using the given formatter.