Enum PulsarError 

pub enum PulsarError {
    Client(ClientError),
    Config(String),
    Schema(SchemaError),
    Other(String),
}

Top-level errors surfaced by the façade.

Variants

Client(ClientError)

Underlying tokio engine error.

Config(String)

Configuration error before any I/O happened.

Schema(SchemaError)

Schema encode / decode error from a crate::TypedProducer / crate::TypedConsumer.

Other(String)

Engine-agnostic error surfaced by a generic façade method that dispatches through an extension trait (e.g. crate::TransactionApi). Carries the runtime’s error message stringified — the per-engine error type is recovered through the runtime crate when full-fidelity diagnostics are needed. Phase 4 of the D1 lift train (ADR-0026 §D1).

Trait Implementations

impl Debug for PulsarError

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

Formats the value using the given formatter.

impl Display for PulsarError

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

Formats the value using the given formatter.

impl Error for PulsarError

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<ClientError> for PulsarError

fn from(source: ClientError) -> Self

Converts to this type from the input type.

impl From<SchemaError> for PulsarError

fn from(source: SchemaError) -> Self

Converts to this type from the input type.