Enum AdapterError 

pub enum AdapterError {
    Transient(String),
    Fatal(String),
    Backpressure,
    Connection(String),
    Shutdown,
    Serialization(Error),
}

Errors that can occur in adapter operations.

Variants

Transient(String)

Transient error - operation can be retried.

Fatal(String)

Fatal error - adapter is in an unrecoverable state.

Backpressure

Backend cannot accept more data - apply backpressure.

Connection(String)

Connection error.

Shutdown

The adapter has been shut down. Distinct from Connection so callers (and the bus’s retry classifier) can tell a “we asked this adapter to stop” reject from a transport failure; pre-fix every post-shutdown on_batch returned Connection, which classified as non-retryable and silently dropped the batch instead of either re-routing or surfacing the shutdown as a distinct state to the caller.

Serialization(Error)

Serialization/deserialization error. Wraps the underlying serde_json::Error so callers can read the category, line, and column via source().

Implementations

impl AdapterError

pub fn is_retryable(&self) -> bool

Returns true if this error is retryable.

pub fn is_fatal(&self) -> bool

Returns true if this error is fatal.

pub fn is_shutdown(&self) -> bool

Returns true if this error means the adapter has been shut down. Callers can react to this without scraping the Connection message string.

Trait Implementations

impl Debug for AdapterError

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

Formats the value using the given formatter.

impl Display for AdapterError

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

Formats the value using the given formatter.

impl Error for AdapterError

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<AdapterError> for ConsumerError

fn from(source: AdapterError) -> Self

Converts to this type from the input type.

impl From<AdapterError> for RpcError

fn from(source: AdapterError) -> Self

Converts to this type from the input type.

impl From<Error> for AdapterError

fn from(source: Error) -> Self

Converts to this type from the input type.