Enum StreamError 

pub enum StreamError {
    Connection {
        message: String,
        source: Option<Box<dyn Error + Send + Sync>>,
        code: Option<i32>,
        labels: Vec<String>,
    },
    Conversion(ConversionError),
    ResumeTokenPersistence(String),
    Invalidated {
        reason: String,
    },
    MaxReconnectAttemptsExceeded(u32),
    InvalidResumeToken {
        code: i32,
    },
    Configuration(String),
}

Errors that can occur during change stream operations.

Variants

Connection

MongoDB connection error (may be retryable)

Fields

message: String

source: Option<Box<dyn Error + Send + Sync>>

code: Option<i32>

MongoDB error code

labels: Vec<String>

MongoDB error labels (e.g., “RetryableWriteError”)

Conversion(ConversionError)

Failed to convert MongoDB event to ChangeEvent

ResumeTokenPersistence(String)

Resume token persistence failed

Invalidated

Stream was invalidated (collection dropped/renamed)

Fields

reason: String

MaxReconnectAttemptsExceeded(u32)

Maximum reconnection attempts exceeded

InvalidResumeToken

Resume token is invalid or oplog truncated (error code 286)

Fields

code: i32

Configuration(String)

Configuration error

Implementations

impl StreamError

pub fn from_mongo_error(err: MongoError) -> Self

Creates a StreamError from a MongoDB error with proper classification.

This method checks error codes and labels for accurate categorization.

pub fn is_retryable(&self) -> bool

Returns true if this error is retryable with reconnection.

Uses MongoDB error codes and labels for accurate classification:

• Error labels: RetryableWriteError, TransientTransactionError, NetworkError
• Transient error codes: 6, 7, 43, 89, 91, 10107, 11600, 11602, 13435, 13436

Non-retryable errors:

• Invalid resume token (286)
• Stream invalidated (collection dropped)
• Authentication/authorization errors

pub fn category(&self) -> &'static str

Returns the error category for metrics/logging.

Trait Implementations

impl Debug for StreamError

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

Formats the value using the given formatter.

impl Display for StreamError

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

Formats the value using the given formatter.

impl Error for StreamError

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<ConversionError> for StreamError

fn from(source: ConversionError) -> Self

Converts to this type from the input type.

impl From<Error> for StreamError

fn from(err: MongoError) -> Self

Converts to this type from the input type.