Enum SubscribeError 

pub enum SubscribeError {
    LocalDelivery(LocalDeliveryError),
    Transport(TransportError),
    Group(Box<GroupError>),
    NotFound(NotFound),
    GroupMessageNotFound,
    ReceiveGroup(Box<GroupMessageProcessingError>),
    Storage(StorageError),
    Decode(DecodeError),
    ApiClient(ApiError),
    BoxError(Box<dyn RetryableError>),
    Db(ConnectionError),
    Conversion(ConversionError),
    Envelope(EnvelopeError),
    Enriched(EnrichMessageError),
    Configuration(Box<ClientError>),
    StreamStale,
}

Variants

LocalDelivery(LocalDeliveryError)

Local message delivery failed. May be retryable for a storage failure.

Transport(TransportError)

The shared native transport failed. May be retryable.

Group(Box<GroupError>)

Group error.

Group operation failed during subscription. May be retryable.

NotFound(NotFound)

Not found.

Subscribed resource not found. Retryable.

GroupMessageNotFound

Group message not found.

Expected message missing from database. Retryable.

ReceiveGroup(Box<GroupMessageProcessingError>)

Receive group error.

Processing streamed group message failed. May be retryable.

Storage(StorageError)

Storage error.

Database operation failed. May be retryable.

Decode(DecodeError)

Decode error.

Protobuf decoding failed. Not retryable.

ApiClient(ApiError)

API client error.

Network request failed. Retryable.

BoxError(Box<dyn RetryableError>)

Boxed error.

Wrapped dynamic error. May be retryable.

Db(ConnectionError)

Database connection error.

Database connection failed. Retryable.

Conversion(ConversionError)

Conversion error.

Proto conversion failed. Not retryable.

Envelope(EnvelopeError)

Envelope error.

Invalid backend envelope. Not retryable.

Enriched(EnrichMessageError)

Enriched Message Error.

Configuration(Box<ClientError>)

The client latched a fatal configuration failure.

Either this database is bound to a different deployment (CFG-051) or the deployment now requires a newer client (CFG-061). Every open stream is closed with it and every later call fails with it. Not retryable.

StreamStale

Stream liveness watchdog tripped.

No activity arrived within the idle timeout, so the stream was terminated to force a reconnect (resuming from the persisted cursor). Retryable.

Implementations

impl SubscribeError

pub fn dyn_err(other: impl RetryableError + 'static) -> Self

Trait Implementations

impl Debug for SubscribeError

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

Formats the value using the given formatter.

impl Display for SubscribeError

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

Formats the value using the given formatter.

impl Error for SubscribeError

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 SubscribeError

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

Returns the unique error code for this error.

impl From<ApiError> for SubscribeError

fn from(source: ApiError) -> Self

Converts to this type from the input type.

impl From<Box<GroupError>> for SubscribeError

fn from(source: Box<GroupError>) -> Self

Converts to this type from the input type.

impl From<Box<GroupMessageProcessingError>> for SubscribeError

fn from(source: Box<GroupMessageProcessingError>) -> Self

Converts to this type from the input type.

impl From<ConnectionError> for SubscribeError

fn from(source: ConnectionError) -> Self

Converts to this type from the input type.

impl From<ConversionError> for SubscribeError

fn from(source: ConversionError) -> Self

Converts to this type from the input type.

impl From<DecodeError> for SubscribeError

fn from(source: DecodeError) -> Self

Converts to this type from the input type.

impl From<EnrichMessageError> for SubscribeError

fn from(source: EnrichMessageError) -> Self

Converts to this type from the input type.

impl From<EnvelopeError> for SubscribeError

fn from(source: EnvelopeError) -> Self

Converts to this type from the input type.

impl From<GroupError> for SubscribeError

fn from(value: GroupError) -> Self

Converts to this type from the input type.

impl From<LocalDeliveryError> for SubscribeError

fn from(source: LocalDeliveryError) -> Self

Converts to this type from the input type.

impl From<NotFound> for SubscribeError

fn from(source: NotFound) -> Self

Converts to this type from the input type.

impl From<StorageError> for SubscribeError

fn from(source: StorageError) -> Self

Converts to this type from the input type.

impl From<SubscribeError> for DeviceSyncError

fn from(source: SubscribeError) -> Self

Converts to this type from the input type.

impl From<TransportError> for SubscribeError

fn from(source: TransportError) -> Self

Converts to this type from the input type.

impl NeedsDbReconnect for SubscribeError

fn needs_db_reconnect(&self) -> bool

Forwards a dropped-pool signal so the device-sync worker stops on disconnect. BoxError wraps an opaque error we can’t introspect → false.

impl RetryableError for SubscribeError

fn is_retryable(&self) -> bool