Enum LocalDeliveryError 

pub enum LocalDeliveryError {
    SessionFailure(Arc<LocalDeliveryError>),
    EnrichedMessageUnavailable,
    NetworkRecoveryExhausted {
        attempts: u32,
        source: Option<Arc<IncomingError>>,
    },
    NetworkFailure(Arc<IncomingError>),
    Configuration(Box<ClientError>),
    Storage(StorageError),
    AcknowledgementRejected,
    AcknowledgementFailed,
    SelectionChanged,
    InvalidConfiguration,
    Closed,
}

Variants

SessionFailure(Arc<LocalDeliveryError>)

Preserve the first terminal failure for every pending token.

EnrichedMessageUnavailable

The retained item has no decoded message. Not retryable.

NetworkRecoveryExhausted

This stream exhausted its network retry budget. Not retryable; a new stream may retry.

Fields

attempts: u32

source: Option<Arc<IncomingError>>

NetworkFailure(Arc<IncomingError>)

A terminal network error stopped this stream. A transient configuration admission failure may be retried by opening a new reader.

Configuration(Box<ClientError>)

The client’s server configuration changed. Not retryable on this client.

Storage(StorageError)

Database receipt, lease, cursor, or acknowledgement failure. May be retryable.

AcknowledgementRejected

The callback failed or its token was dropped before acknowledgement. Not retryable.

AcknowledgementFailed

A previous acknowledgement write failed. Reopen to retry delivery. Not retryable.

SelectionChanged

Scope, filters, or retained content changed before dispatch. Reselect without acknowledgement.

InvalidConfiguration

The batch or timing settings cannot maintain a valid consumer lease. Not retryable.

Closed

This reader has been closed. Not retryable.

Trait Implementations

impl Debug for LocalDeliveryError

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

Formats the value using the given formatter.

impl Display for LocalDeliveryError

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

Formats the value using the given formatter.

impl Error for LocalDeliveryError

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 LocalDeliveryError

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

Returns the unique error code for this error.

impl From<LocalDeliveryError> for SubscribeError

fn from(source: LocalDeliveryError) -> Self

Converts to this type from the input type.

impl From<StorageError> for LocalDeliveryError

fn from(source: StorageError) -> Self

Converts to this type from the input type.

impl RetryableError for LocalDeliveryError

fn is_retryable(&self) -> bool