Enum PostgresOutboxError 

#[non_exhaustive]
pub enum PostgresOutboxError {
    NotMigrated {
        source: Error,
    },
    Database {
        source: Error,
    },
}

A failure of a crate::PostgresOutboxStore OutboxStore/OutboxDeadLetters call — never a property of one row’s content. Row-content problems surface as reliar_outbox::PoisonedRows instead (ADR 0008).

Classify tells a dispatcher whether a failed call is worth retrying. The bare PostgresOutboxStore below leans on its default type parameter, gated on the default json feature; without it this block still shows the shape but is not compiled.

use reliar_core::Classify;
use reliar_outbox::{AcquireRequest, OutboxStore, WorkerId};

let request = AcquireRequest::new(WorkerId::generate());
if let Err(err) = store.acquire(request).await {
    eprintln!("acquire failed ({:?}): {err}", err.kind());
}

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.

NotMigrated

The relation does not resolve on this connection’s search_path (SQLSTATE 42P01). Either migrate() has not run, or the connection’s search_path does not resolve the unqualified name outbox to the migrated schema. Permanent — the table does not appear on its own. Reliar does not check this at construction (ADR 0047); this is the first statement reporting it, with PostgreSQL’s own message attached as the source. Mapped from SQLSTATE 42P01 on every call.

Fields

source: Error

The underlying 42P01 error, returned from std::error::Error::source.

Database

Connection lost, statement timeout, pool exhausted, deadlock, or any other sqlx failure not mapped to a more specific variant above. Classified by the wrapped SQLSTATE’s class (never blanket-transient — see the Classify impl below).

Fields

source: Error

The underlying sqlx error.

Trait Implementations

impl Classify for PostgresOutboxError

Per-variant classification table — no blanket “everything else is transient”. A wrong verdict is not cosmetic: Transient burns the dispatcher’s retry budget on a failure that can never succeed; Permanent kills a message that would have gone through on the next attempt.

fn kind(&self) -> FailureKind

Whether the failure this error represents can succeed on retry.

impl Debug for PostgresOutboxError

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

Formats the value using the given formatter.

impl Display for PostgresOutboxError

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

Formats the value using the given formatter.

impl Error for PostgresOutboxError

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 PostgresOutboxError

fn from(source: Error) -> Self

Converts to this type from the input type.