Enum ZerobusError 

pub enum ZerobusError {
    ConfigurationError(String),
    AuthenticationError(String),
    ConnectionError(String),
    ConversionError(String),
    TransmissionError(String),
    RetryExhausted(String),
    TokenRefreshError(String),
}

Error type for wrapper operations

All errors are descriptive and actionable, providing sufficient information for developers to diagnose and resolve issues.

Variants

ConfigurationError(String)

Invalid configuration error

Occurs when configuration values are invalid or missing required fields.

AuthenticationError(String)

Authentication failure error

Occurs when authentication with Zerobus fails (invalid credentials, expired tokens, etc.).

ConnectionError(String)

Network/connection error

Occurs when network connectivity is lost or connection to Zerobus fails.

ConversionError(String)

Arrow to Protobuf conversion failure

Occurs when Arrow RecordBatch data cannot be converted to Protobuf format.

TransmissionError(String)

Data transmission failure

Occurs when data transmission to Zerobus fails.

RetryExhausted(String)

All retry attempts exhausted

Occurs when all retry attempts for transient failures have been exhausted.

TokenRefreshError(String)

Token refresh failure

Occurs when authentication token refresh fails.

Implementations

impl ZerobusError

pub fn is_retryable(&self) -> bool

Check if the error is retryable

Returns true for transient errors that should be retried:

• ConnectionError
• TransmissionError (if transient)

pub fn is_token_expired(&self) -> bool

Check if the error indicates token expiration

Returns true if the error suggests the authentication token has expired.

Trait Implementations

impl Clone for ZerobusError

fn clone(&self) -> ZerobusError

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ZerobusError

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

Formats the value using the given formatter.

impl Display for ZerobusError

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

Formats the value using the given formatter.

impl Error for ZerobusError

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.