Enum ConsumerError 

pub enum ConsumerError {
    ConnectionFailed(String),
    DecompressionFailed(String),
    DeserializationFailed(String),
    HandlerRegistrationFailed(String),
    EventSenderNotInitialized(String),
    MessageConversionFailed(String),
    UpdateSerializationFailed(String),
    UpdateSendFailed(String),
    DecompressorCreationFailed(String),
}

Errors that can occur when consuming events from the Jetstream service

Variants

ConnectionFailed(String)

Occurs when WebSocket connection establishment or maintenance fails

DecompressionFailed(String)

Occurs when message decompression using zstd dictionary fails

DeserializationFailed(String)

Occurs when deserializing Jetstream events from JSON fails

HandlerRegistrationFailed(String)

Occurs when attempting to register event handlers after consumer has started

EventSenderNotInitialized(String)

Occurs when event sender channel is not properly initialized

MessageConversionFailed(String)

Occurs when converting WebSocket messages to expected format fails

UpdateSerializationFailed(String)

Occurs when serializing update messages for transmission fails

UpdateSendFailed(String)

Occurs when sending updates through WebSocket connection fails

DecompressorCreationFailed(String)

Occurs when creating zstd decompressor with dictionary fails

Trait Implementations

impl Debug for ConsumerError

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

Formats the value using the given formatter.

impl Display for ConsumerError

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

Formats the value using the given formatter.

impl Error for ConsumerError

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.