Enum BusError 

#[non_exhaustive]
pub enum BusError {
    UnknownTopic(String),
    Io(Error),
    Serde(Error),
    Backend(String),
}

Bus errors.

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.

UnknownTopic(String)

Topic does not exist (provision first — publishing into the void is a silent-error class, so it’s an error, not an auto-create).

Io(Error)

I/O failure.

Serde(Error)

Serialization failure.

Backend(String)

Backend-specific failure (network brokers).

Implementations

impl BusError

pub fn is_permanent(&self) -> bool

Distinguish permanent config errors from transient outages so downstream error mapping can route them to the right HTTP status. UnknownTopic is a misconfiguration — the topic must be provisioned via the manifest before publishing, so a retry without operator action cannot succeed. Serde is a wire-shape violation from the sender — also permanent for that specific payload. Io and Backend are transient by default (network blip, disk temporarily full, broker restarting); reclassifying specific-message shapes here would require pattern-matching the underlying error, which is fragile.

Callers should use is_permanent() to decide whether to return HTTP 400/409 (permanent, no Retry-After) or 503 (transient, with Retry-After) — see av-harness::routes::finalize_error_response.

Trait Implementations

impl Debug for BusError

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

Formats the value using the given formatter.

impl Display for BusError

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

Formats the value using the given formatter.

impl Error for BusError

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<Error> for BusError

fn from(source: Error) -> Self

Converts to this type from the input type.

impl From<Error> for BusError

fn from(source: Error) -> Self

Converts to this type from the input type.