Struct EnqueueRequest 

pub struct EnqueueRequest { /* private fields */ }

A job to enqueue, built fluently.

Start with EnqueueRequest::new (which requires a queue and a job type) and layer on the optional fields with the with_* methods. Pass the result to SeppClient::enqueue, enqueue_batch, or enqueue_atomic.

use sepp_rs::{EnqueueRequest, Payload, Priority};

let req = EnqueueRequest::new("emails", "send_welcome")?
    .with_payload(Payload::new(b"{}".to_vec(), "application/json"))
    .with_priority(Priority::P7)
    .with_idempotency_key("welcome-user-42")
    .with_max_attempts(5);

Fields left unset fall back to the queue’s configured defaults on the server.

Implementations

impl EnqueueRequest

pub fn new( queue: impl Into<String>, job_type: impl Into<String>, ) -> Result<Self, EnqueueRequestBuilderError>

Begins a request for the given queue and job type.

Both must be non-empty, or EnqueueRequestBuilderError is returned.

pub fn with_payload(self, payload: Payload) -> Self

Sets the job’s payload. Its data and encoding must be non-empty — leave the payload unset for jobs that carry no data (see Payload).

pub fn with_idempotency_key(self, key: impl Into<String>) -> Self

Sets a deduplication key. The server drops a duplicate enqueue with the same key within the queue’s dedup window, returning the existing job’s id with EnqueueAck::deduplicated set.

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

Overrides the queue’s default Priority.

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

Overrides the queue’s default maximum delivery attempts before the job is dead-lettered.

pub fn with_custom(self, custom: HashMap<String, Primitive>) -> Self

Replaces the custom metadata map wholesale. See with_custom_entry to add one key at a time.

pub fn with_custom_entry( self, key: impl Into<String>, value: impl Into<Primitive>, ) -> Self

Inserts a single custom metadata entry. Any type that converts into a Primitive (&str, i64, bool, …) is accepted as the value.

pub fn with_trace_context(self, trace_context: TraceContext) -> Self

Attaches a TraceContext to the job.

With the opentelemetry feature, the current span’s context is injected automatically at enqueue time, so set this only to override that or to propagate a trace captured elsewhere.

pub fn with_scheduled_at(self, scheduled_at: SystemTime) -> Self

Delays the job until the given time. The job is not delivered to any worker before then. Must be within the server’s max_schedule_horizon, or the job is rejected with JobRejection::ScheduledTooFar.

Trait Implementations

impl Clone for EnqueueRequest

fn clone(&self) -> EnqueueRequest

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for EnqueueRequest

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

Formats the value using the given formatter.

impl From<&DeadLetterRecord> for EnqueueRequest

fn from(r: &DeadLetterRecord) -> Self

Replays a dead-lettered job into its original queue, leaving the record intact.

impl From<DeadLetterRecord> for EnqueueRequest

fn from(r: DeadLetterRecord) -> Self

Replays a dead-lettered job into its original queue, consuming the record.