Enum QueueError 

pub enum QueueError {
    NotFound(Uuid),
    InvalidStatus {
        entry_id: Uuid,
        expected: &'static str,
        actual: String,
    },
    LeaseExpired(Uuid),
    LeaseOwnerMismatch {
        entry_id: Uuid,
        expected: String,
        actual: String,
    },
    DuplicateTask(Uuid),
    ConcurrencyCapExceeded(String),
    Database(String),
    Runtime(String),
    InvalidQueueStatus(String),
    InvalidCommandClass(String),
}

Errors from task queue operations.

Variants

NotFound(Uuid)

Entry not found in the queue.

InvalidStatus

Entry is not in the expected status for this operation.

Fields

entry_id: Uuid

expected: &'static str

actual: String

LeaseExpired(Uuid)

Lease has expired and was reclaimed.

LeaseOwnerMismatch

Lease owner mismatch — another worker holds the lease.

Fields

entry_id: Uuid

expected: String

actual: String

DuplicateTask(Uuid)

Duplicate task_id already in queue for this run.

ConcurrencyCapExceeded(String)

Concurrency cap exceeded.

Database(String)

Database operation failed.

Runtime(String)

Tokio runtime operation failed.

InvalidQueueStatus(String)

Persisted queue status is invalid.

InvalidCommandClass(String)

Persisted command class is invalid.

Trait Implementations

impl Debug for QueueError

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

Formats the value using the given formatter.

impl Display for QueueError

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

Formats the value using the given formatter.

impl Error for QueueError

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<QueueError> for SchedulerError

fn from(source: QueueError) -> Self

Converts to this type from the input type.