Enum Error 

pub enum Error {
    Backend(Box<dyn Error + Send + Sync>),
    Json(Error),
    NotFound(String),
    JobNotFound {
        queue_name: String,
        id: String,
    },
    RateLimitExceeded {
        current: f64,
        limit: i32,
        reset_at: OffsetDateTime,
    },
    LockFailed(String),
    LockTimeout(i32),
    PayloadTooLarge {
        size: usize,
        max_size: usize,
    },
    ChannelClosed(String),
}

Errors that can occur during infrastructure operations.

Backend-specific errors (sqlx, redis, etc.) are wrapped in Error::Backend.

Variants

Backend(Box<dyn Error + Send + Sync>)

Backend-specific error (sqlx::Error, redis::Error, etc.).

Json(Error)

JSON serialization/deserialization error.

NotFound(String)

Key not found in cache or counter.

JobNotFound

Job not found in queue.

After the PARTITION BY LIST (queue_name) migration, every id-based JobQueue operation scopes the lookup to a specific partition via queue_name. A JobNotFound can therefore mean either “no job with this id in this queue” (the genuine case) or “the caller passed the wrong queue_name for a real id” (a programming bug). Carrying both fields lets operators distinguish the two in logs.

Fields

queue_name: String

The queue the caller asked for.

id: String

The job id the caller asked for.

RateLimitExceeded

Rate limit exceeded.

Fields

current: f64

Current weighted request count.

limit: i32

Maximum allowed requests.

reset_at: OffsetDateTime

When the rate limit resets.

LockFailed(String)

Lock acquisition failed (already held by another session).

LockTimeout(i32)

Lock acquisition timed out.

PayloadTooLarge

Payload too large for the backend’s notification limit.

Fields

size: usize

Actual payload size in bytes.

max_size: usize

Maximum allowed size in bytes.

ChannelClosed(String)

Internal channel closed (background task exited).

Implementations

impl Error

pub fn backend(err: impl Error + Send + Sync + 'static) -> Self

Wrap a backend-specific error.

pub fn is_rate_limited(&self) -> bool

Returns true if this is a rate limit exceeded error.

pub fn is_not_found(&self) -> bool

Returns true if this is a not found error.

pub fn is_lock_error(&self) -> bool

Returns true if this is a lock-related error.

pub fn reset_at(&self) -> Option<OffsetDateTime>

Extract rate limit reset time if this is a rate limit error.

Trait Implementations

impl Debug for Error

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

Formats the value using the given formatter.

impl Display for Error

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

Formats the value using the given formatter.

impl Error for Error

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 From<Error> for Error

fn from(source: Error) -> Self

Converts to this type from the input type.