Enum OutboxError 

pub enum OutboxError {
    InfrastructureError(String),
    DuplicateEvent,
    DatabaseError(String),
    BrokerError(String),
    ConfigError(String),
}

Error categories produced by the outbox crate.

The variants correspond to the layer that originated the failure. When a caller needs to decide whether to retry, the variant is usually enough — most transient conditions show up as InfrastructureError, DatabaseError, or BrokerError; configuration and deduplication issues are terminal.

Variants

InfrastructureError(String)

Failure from surrounding infrastructure that is not the primary database or broker (Redis, a notification channel, DNS, etc.). Usually transient.

DuplicateEvent

The event’s idempotency token has already been reserved by a prior call. Returned by OutboxService::add_event when IdempotencyStorageProvider::try_reserve reports the token as taken. Not retryable.

DatabaseError(String)

Failure from the primary event store (for example SQL errors, pool exhaustion, serialization conflicts). Often retryable by the caller.

BrokerError(String)

Failure from the message transport (Kafka, Redis Streams, etc.) when publishing an event.

ConfigError(String)

Invalid or incomplete configuration discovered at wiring time — typically raised by OutboxManagerBuilder::build when a required collaborator is missing. Not retryable.

Trait Implementations

impl Debug for OutboxError

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

Formats the value using the given formatter.

impl Display for OutboxError

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

Formats the value using the given formatter.

impl Error for OutboxError

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.