Enum JobRejection 

#[non_exhaustive]
pub enum JobRejection {
    UnknownQueue {
        queue: String,
    },
    PayloadTooLarge {
        limit: u64,
        actual: u64,
    },
    EncodingNotAllowed {
        encoding: String,
        allowed: Vec<String>,
    },
    JobTypeNotAllowed {
        job_type: String,
        allowed: Vec<String>,
    },
    CustomEntriesTooMany {
        limit: u32,
        actual: u32,
    },
    CustomMapTooLarge {
        limit: u64,
        actual: u64,
    },
    CustomKeyTooLong {
        key: String,
        limit: u32,
        actual: u64,
    },
    QueueNameTooLong {
        limit: u32,
        actual: u64,
    },
    JobTypeNameTooLong {
        limit: u32,
        actual: u64,
    },
    IdempotencyKeyTooLong {
        limit: u32,
        actual: u64,
    },
    ScheduledTooFar {
        horizon: Duration,
        actual: SystemTime,
    },
    InvalidRequest {
        message: String,
    },
    QueueFull {
        queue: String,
        limit: u64,
    },
    QueueClosing {
        queue: String,
    },
    Unknown,
}

Why the server refused a single job.

Every variant except QueueFull and QueueClosing is deterministic: re-sending the same job against the same server state produces the same rejection. Transient problems (a storage outage, a dropped connection) are never reported here — they surface as a ClientError instead. Most limits behind these variants are advertised up front by ServerInfo, so a producer can validate locally before sending.

Variants (Non-exhaustive)

Non-exhaustive enums could have additional variants added in future. Therefore, when matching against variants of non-exhaustive enums, an extra wildcard arm must be added to account for any future variants.

UnknownQueue

The server is in strict mode and the target queue has not been declared.

Fields

queue: String

PayloadTooLarge

The payload exceeds the queue’s max_payload_bytes.

Fields

limit: u64

actual: u64

EncodingNotAllowed

The queue restricts encodings and the payload’s encoding is not on the allow-list.

Fields

encoding: String

allowed: Vec<String>

JobTypeNotAllowed

The queue restricts job types and this one is not on the allow-list.

Fields

job_type: String

allowed: Vec<String>

CustomEntriesTooMany

The custom map has more entries than max_custom_entries.

Fields

limit: u32

actual: u32

CustomMapTooLarge

The custom map’s total size exceeds max_custom_total_bytes.

Fields

limit: u64

actual: u64

CustomKeyTooLong

A custom key exceeds max_custom_key_bytes.

Fields

key: String

limit: u32

actual: u64

QueueNameTooLong

The queue name exceeds max_queue_name_bytes.

Fields

limit: u32

actual: u64

JobTypeNameTooLong

The job type exceeds max_job_type_bytes.

Fields

limit: u32

actual: u64

IdempotencyKeyTooLong

The idempotency key exceeds max_idempotency_key_bytes.

Fields

limit: u32

actual: u64

ScheduledTooFar

scheduled_at is further out than max_schedule_horizon.

Fields

horizon: Duration

actual: SystemTime

InvalidRequest

The request failed the server’s structural validation (e.g. a required field was missing); message carries the detail.

Fields

message: String

QueueFull

The target queue is at capacity (limit is its configured max depth). Non-deterministic: it clears once the queue drains.

Fields

queue: String

limit: u64

QueueClosing

The target queue is being deleted and is not accepting new jobs. Non-deterministic: it clears once the delete completes or is abandoned.

Fields

queue: String

Unknown

The server sent a rejection reason this client version does not recognize.

Trait Implementations

impl Clone for JobRejection

fn clone(&self) -> JobRejection

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for JobRejection

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

Formats the value using the given formatter.

impl Display for JobRejection

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

Formats the value using the given formatter.

impl Error for JobRejection

fn source(&self) -> Option<&(dyn Error + 'static)>

Returns the lower-level source of this error, if any.

fn description(&self) -> &str

👎Deprecated since 1.42.0:

use the Display impl or to_string()

fn cause(&self) -> Option<&dyn Error>

👎Deprecated since 1.33.0:

replaced by Error::source, which can support downcasting

fn provide<'a>(&'a self, request: &mut Request<'a>)

🔬This is a nightly-only experimental API. (error_generic_member_access)

Provides type-based access to context intended for error reports.

impl PartialEq for JobRejection

fn eq(&self, other: &JobRejection) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for JobRejection