Enum RepositoryError 

pub enum RepositoryError {
    LockPoisoned(&'static str),
    Lock(LockError),
    ConcurrentWrite {
        id: String,
        expected: u64,
        actual: u64,
    },
    DuplicateStreamInBatch {
        id: String,
    },
    DuplicateOutboxMessageInBatch {
        id: String,
    },
    DuplicateInboxReceipt {
        consumer: String,
        message_id: String,
    },
    InvalidInboxReceipt {
        consumer: String,
        message_id: String,
    },
    InvalidStreamIdentity {
        aggregate_type: String,
        aggregate_id: String,
        reason: String,
    },
    NotFound {
        id: String,
    },
    InvalidState {
        id: String,
        expected: &'static str,
        actual: String,
    },
    Replay(String),
    Model(String),
}

Variants

LockPoisoned(&'static str)

Lock(LockError)

ConcurrentWrite

Fields

id: String

expected: u64

actual: u64

DuplicateStreamInBatch

Fields

id: String

DuplicateOutboxMessageInBatch

Fields

id: String

DuplicateInboxReceipt

A consumer inbox receipt (consumer, message_id) was already recorded. The commit is rolled back so the consumer’s effects are not double-applied; the message has already been processed (an at-least-once replay).

Fields

consumer: String

message_id: String

InvalidInboxReceipt

A consumer inbox receipt had an empty consumer or message_id. Rejected uniformly across backends before any write (the relational CHECK constraints are a defense-in-depth backstop).

Fields

consumer: String

message_id: String

InvalidStreamIdentity

Fields

aggregate_type: String

aggregate_id: String

reason: String

NotFound

Fields

id: String

InvalidState

Fields

id: String

expected: &'static str

actual: String

Replay(String)

Model(String)

Trait Implementations

impl Clone for RepositoryError

fn clone(&self) -> RepositoryError

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for RepositoryError

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

Formats the value using the given formatter.

impl Display for RepositoryError

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

Formats the value using the given formatter.

impl Error for RepositoryError

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<EventRecordError> for RepositoryError

fn from(err: EventRecordError) -> Self

Converts to this type from the input type.

impl From<LockError> for RepositoryError

fn from(err: LockError) -> Self

Converts to this type from the input type.

impl From<ReadModelError> for RepositoryError

fn from(err: ReadModelError) -> Self

Converts to this type from the input type.

impl From<RepositoryError> for HandlerError

fn from(err: RepositoryError) -> Self

Converts to this type from the input type.

impl From<RepositoryError> for TransportError

Repository/store failures (lock contention, storage hiccups, stale-claim conflicts) are retryable: usually transient, resolved by a later re-claim. This conversion lives with the outbox bridge — which legitimately knows both the store and the bus — so bus core stays free of RepositoryError.

fn from(error: RepositoryError) -> Self

Converts to this type from the input type.

impl PartialEq for RepositoryError

fn eq(&self, other: &RepositoryError) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Eq for RepositoryError

impl StructuralPartialEq for RepositoryError