Enum PostgresStoreError 

#[non_exhaustive]
pub enum PostgresStoreError {
    SchemaResolution {
        configured: String,
        observed: String,
    },
    NotMigrated {
        schema: String,
    },
    Database {
        source: Error,
    },
    Decode {
        id: MessageId,
        detail: String,
    },
    UnknownMetadataVersion {
        id: MessageId,
        version: i32,
    },
    DuplicateMessage {
        id: MessageId,
    },
    InvalidSchema {
        schema: String,
    },
    UnsupportedServerVersion {
        required: u32,
        detected: u32,
    },
}

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:

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.

SchemaResolution

The unqualified name outbox does not resolve, or resolves to a different schema than configured. Carries the configured schema and the observed search_path; the ALTER ROLE remedy is in the Display text. Permanent.

Fields

configured: String

The schema PostgresOutboxSettings::schema named.

observed: String

The search_path Postgres reported at construction.

NotMigrated

outbox resolved to the configured schema, but the relation itself is missing — migrate() has not been run. Permanent. Mapped from SQLSTATE 42P01 on every path, not just startup verification.

Fields

schema: String

The configured schema.

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.

Decode

A claimed or listed row could not be turned into an OutboxRecord (a corrupt JSONB remainder, an unparseable promoted column). Surfaces as a poisoned row, never as an acquire/list_dead failure. Permanent — the bytes on disk do not change between attempts.

Fields

id: MessageId

The row’s message id.

detail: String

A short, payload-free description of what failed to decode.

UnknownMetadataVersion

The row’s metadata_version is not one this build knows how to read. Permanent — it needs a newer reader, not another try.

Fields

id: MessageId

The row’s message id.

version: i32

The unrecognised version.

DuplicateMessage

enqueue inserted a MessageId that already exists (pk_outbox violation). Permanent — a reused id never succeeds on retry; the row is already there.

Fields

id: MessageId

The id the caller tried to reuse.

InvalidSchema

PostgresOutboxSettings::schema or MigrateOptions::schema is not a valid PostgreSQL identifier ([a-z_][a-z0-9_$]*, at most 63 bytes, lowercase only) — checked once, before it is ever interpolated into SET search_path/dangerous_set_table_name. Lowercase-only rather than merely case-insensitive: PostgreSQL folds an unquoted identifier to lowercase, so an uppercase configured name and the schema it actually resolves to would silently disagree unless every one of migrate()’s, verify_schema’s and the host’s own search_path configuration happened to quote it the same way everywhere — rejecting it up front removes the whole class of mismatch. Permanent — configuration, not weather.

Fields

schema: String

The rejected schema name.

UnsupportedServerVersion

The connected server’s server_version_num is below crate::MIN_SERVER_VERSION_NUM (PostgreSQL 18, ADR 0041 / human decision #47) — no older-version fallback. Checked at crate::PostgresOutboxStore::connect, before the search_path verification above: a wrong server version explains a missing relation, and the reverse is never true. Carries no connection string, host, or credentials. Permanent.

Fields

required: u32

crate::MIN_SERVER_VERSION_NUM, restated on the value so this variant is self-describing without a second lookup.

detected: u32

The server_version_num this connection reported.

Trait Implementations

impl Classify for PostgresStoreError

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 PostgresStoreError

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

Formats the value using the given formatter.

impl Display for PostgresStoreError

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

Formats the value using the given formatter.

impl Error for PostgresStoreError

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 PostgresStoreError

fn from(source: Error) -> Self

Converts to this type from the input type.