Struct AddJob 

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

Fluent builder returned by Queue::add.

AddJob implements IntoFuture, so awaiting it adds the job with the accumulated options. Setters are infallible and chainable; any invalid configuration (or a data serialization failure) is reported when the builder is awaited.

Implementations

impl<'a> AddJob<'a>

pub fn options(self, opts: JobOptions) -> Self

Use opts as the base options, replacing anything set so far.

Useful for reusing a prepared JobOptions; subsequent setters still override individual fields.

pub fn delay(self, delay: Duration) -> Self

Delay before the job becomes available for processing.

pub fn priority(self, priority: u32) -> Self

Job priority. Lower values are processed first; unset (or 0) means the job is not prioritized and follows normal FIFO/LIFO ordering.

pub fn attempts(self, attempts: u32) -> Self

Total number of attempts before the job permanently fails.

pub fn backoff(self, backoff: BackoffStrategy) -> Self

Backoff strategy applied between retries.

pub fn lifo(self) -> Self

Add the job to the back of the queue (last-in-first-out ordering).

pub fn job_id(self, id: impl Into<String>) -> Self

Use a custom, unique job id instead of an auto-generated one.

pub fn remove_on_complete(self, policy: RemoveOnFinish) -> Self

Completed-job retention policy.

pub fn remove_on_fail(self, policy: RemoveOnFinish) -> Self

Failed-job retention policy.

pub fn keep_logs(self, count: u32) -> Self

Maximum number of log entries to retain for the job.

pub fn parent(self, parent: ParentOptions) -> Self

Attach this job to a parent job (flow / dependency chains).

pub fn deduplication(self, deduplication: DeduplicationOptions) -> Self

Deduplicate the job using the given options.

pub fn size_limit(self, bytes: usize) -> Self

Reject the job if its serialized payload exceeds bytes UTF-8 bytes.

Trait Implementations

impl<'a> IntoFuture for AddJob<'a>

type Output = Result<Job, Error>

The output that the future will produce on completion.

type IntoFuture = Pin<Box<dyn Future<Output = <AddJob<'a> as IntoFuture>::Output> + Send + 'a>>

Which kind of future are we turning this into?

fn into_future(self) -> Self::IntoFuture

Creates a future from a value.