Enum ZerobusSinkError 

#[non_exhaustive]
pub enum ZerobusSinkError {
    Transient(String),
    Poison(String),
    FatalConfig(String),
    WriteBoundary(String),
    Catalog(String),
    Encode(String),
}

Everything that can go wrong in the Zerobus sink.

Variants (Non-exhaustive)

Non-exhaustive enums could have additional variants added in future. Therefore, when matching against variants of non-exhaustive enums, an extra wildcard arm must be added to account for any future variants.

Transient(String)

A transient transport error — retry on the existing stream after backoff.

Poison(String)

The stream is unrecoverable and must be rebuilt (closed transport, credential revoked, unexpected permanent transport error).

FatalConfig(String)

Configuration is invalid and the sink must not start / must fail loudly (e.g. a primary-raw precondition is unmet).

WriteBoundary(String)

A write-boundary type mismatch that could not be reconciled, with the offending column named — never an opaque per-batch rejection.

Catalog(String)

The table catalog (provisioning / credential vending) failed.

Encode(String)

Encoding the Arrow batch to IPC bytes failed.

Implementations

impl ZerobusSinkError

pub fn class(&self) -> ErrorClass

The recovery class of this error.

pub fn is_transient(&self) -> bool

Whether the error should be retried on the existing stream after backoff.

pub fn from_transport(retryable: bool, message: impl Into<String>) -> Self

Map a transport-level “retryable?” flag (as the Databricks SDK reports via ZerobusError::is_retryable) to the sink’s transient/poison split.

Trait Implementations

impl Debug for ZerobusSinkError

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

Formats the value using the given formatter.

impl Display for ZerobusSinkError

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

Formats the value using the given formatter.

impl Error for ZerobusSinkError

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<ZerobusSinkError> for SinkError

fn from(e: ZerobusSinkError) -> Self

Converts to this type from the input type.