bus-core 0.1.1

Core traits and types for eventbus-rs with zero NATS dependencies
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38

use thiserror::Error;

/// Errors returned by handler implementations.
#[derive(Debug, Error)]
pub enum HandlerError {
    /// Transient failure: the message should be retried.
    #[error("transient: {0}")]
    Transient(String),

    /// Permanent failure: the message should not be retried.
    #[error("permanent: {0}")]
    Permanent(String),
}

/// Top-level error type for event bus operations.
#[derive(Debug, Error)]
pub enum BusError {
    #[error("nats: {0}")]
    Nats(String),

    #[error("publish: {0}")]
    Publish(String),

    #[error("outbox: {0}")]
    Outbox(String),

    #[error("idempotency: {0}")]
    Idempotency(String),

    #[error("serialization: {0}")]
    Serde(#[from] serde_json::Error),

    #[error("handler: {0}")]
    Handler(#[from] HandlerError),

    #[error("nats unavailable")]
    NatsUnavailable,
}