Struct CatalogJobEnqueueInput 

pub struct CatalogJobEnqueueInput<'a> {
    pub job_type: &'a str,
    pub organization_id: Option<Uuid>,
    pub payload: &'a Value,
    pub priority: Option<i32>,
    pub max_attempts: Option<i32>,
    pub timeout_seconds: Option<i32>,
    pub next_run_at: Option<DateTime<Utc>>,
    pub idempotency_key: Option<&'a str>,
    pub stage: Option<JobStage>,
}

Input for building a JobEnqueue from a catalog-backed job type.

Fields

job_type: &'a str

Catalog job type to enqueue.

organization_id: Option<Uuid>

Optional organization scope copied to the queued job.

payload: &'a Value

JSON payload stored with the queued job.

priority: Option<i32>

Optional queue priority override.

max_attempts: Option<i32>

Optional maximum-attempts override.

timeout_seconds: Option<i32>

Optional execution timeout override, in seconds.

next_run_at: Option<DateTime<Utc>>

Optional future time before which the job should not run.

idempotency_key: Option<&'a str>

Optional idempotency key for duplicate enqueue protection.

stage: Option<JobStage>

Optional initial job stage.

Trait Implementations

impl<'a> Clone for CatalogJobEnqueueInput<'a>

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

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<'a> Debug for CatalogJobEnqueueInput<'a>

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

Formats the value using the given formatter.