Enum StreamStorageError 

pub enum StreamStorageError {
    InvalidBatch,
    MissingPrefix {
        after: u64,
        received: u64,
    },
    UninitializedNetworkProgress,
    Capacity {
        scope: BudgetScope,
    },
    HeadChanged,
    StaleJoinAnchor,
    AlreadyActive,
    NotCurrentOwner,
    ForeignCursor,
    DeliveryExhausted,
    LocalReadCapacity {
        bytes: u64,
        limit: u64,
    },
    InvalidDeliveryPosition,
}

Stable storage failures that preserve receipt, processing, and delivery invariants.

Variants

InvalidBatch

The batch does not have valid, strictly increasing envelope IDs.

MissingPrefix

The source omitted a prefix not yet stored in this database.

Fields

after: u64

received: u64

UninitializedNetworkProgress

Existing progress was not written by ordered admission.

Capacity

Pending work exceeds its row or byte budget. Retry after processing drains it.

Fields

scope: BudgetScope

HeadChanged

Another processor changed the pending head. Reload state before retrying.

StaleJoinAnchor

Installing this welcome would rewind or replace processed state.

AlreadyActive

Another default consumer holds an unexpired lease.

NotCurrentOwner

The lease expired or a new consumer acquired ownership.

ForeignCursor

The cursor was issued before restore or by another database.

DeliveryExhausted

The persistent local message counter cannot allocate another number.

LocalReadCapacity

The next retained message exceeds the local read byte limit. Not retryable.

Fields

bytes: u64

limit: u64

InvalidDeliveryPosition

The cursor is ahead of local history or the lease interval is empty.

Trait Implementations

impl Debug for StreamStorageError

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

Formats the value using the given formatter.

impl Display for StreamStorageError

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

Formats the value using the given formatter.

impl Error for StreamStorageError

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 ErrorCode for StreamStorageError

fn error_code(&self) -> &'static str

Returns the unique error code for this error.

impl From<StreamStorageError> for StorageError

fn from(source: StreamStorageError) -> Self

Converts to this type from the input type.

impl RetryableError for StreamStorageError

fn is_retryable(&self) -> bool