Enum StoreError 

pub enum StoreError {
    Duplicate {
        existing_id: String,
        replaced: bool,
    },
    IdConflict {
        job_id: String,
    },
    Quarantined {
        fingerprint: String,
    },
    Backpressure {
        queue: String,
        limit: u64,
        current: u64,
        incoming: u64,
    },
    LeaseRejected {
        job_id: String,
    },
    Unavailable(String),
    NotFound(String),
    Invalid(String),
    Backend(String),
}

Variants

Duplicate

job uniqueness duplicate unique key. Carries the winner so the caller can join rather than guess. A normal result, not an exception — and never a silent skip.

Fields

existing_id: String

replaced: bool

True when the requested allowlisted fields were atomically written to the existing non-running holder. It remains a duplicate result so the caller still receives the winner’s id (job uniqueness).

IdConflict

idempotent enqueue identity a caller-supplied Envelope.id that already names a row whose CONTENT differs. Distinct from Duplicate: that one is best-effort uniqueness over a key the caller chose to opt into, this one is the strict per-id guarantee asynq separates as TaskID(id) + ErrTaskIDConflict. Its own variant because the two carry different information (the winner’s id vs. the id you asked for, which are the same string here) and map to different API bodies; folding it into Invalid — where it lived before — surfaced a 409 condition as a 400.

Fields

job_id: String

Quarantined

crash quarantine enqueue of a quarantined fingerprint is rejected until an operator releases.

Fields

fingerprint: String

Backpressure

Producer-side admission control. The store evaluated this against its exact, incrementally-maintained unfinished count while serializing producers for the queue; callers may retry after capacity is released, route elsewhere, or shed.

Fields

queue: String

limit: u64

current: u64

incoming: u64

LeaseRejected

lease fencing the caller no longer holds this lease (reclaimed, or superseded by a newer fence). The worker must stop this job immediately.

Fields

job_id: String

Unavailable(String)

typed availability errors the store is unreachable. Typed apart from validation so callers can choose between failing the request, degrading, or buffering themselves.

NotFound(String)

The addressed job/resource does not exist.

Invalid(String)

A request rejected at the boundary — e.g. a duration that rounds to zero (boundary validation).

Backend(String)

Trait Implementations

impl Debug for StoreError

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

Formats the value using the given formatter.

impl Display for StoreError

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

Formats the value using the given formatter.

impl Error for StoreError

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.