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

use crate::{error::HandlerError, event::Event, id::MessageId};
use async_trait::async_trait;
use tracing::Span;

/// Context passed to every handler invocation.
#[derive(Debug)]
pub struct HandlerCtx {
    /// The message ID associated with this delivery.
    pub msg_id: MessageId,

    /// Stream sequence number for this message.
    pub stream_seq: u64,

    /// Number of times this message has been delivered.
    pub delivered: u64,

    /// Subject this message was received on.
    pub subject: String,

    /// Active tracing span for attaching handler work.
    pub span: Span,
}

/// Processes a strongly typed event received from the event bus.
#[async_trait]
pub trait EventHandler<E: Event>: Send + Sync + 'static {
    async fn handle(&self, ctx: HandlerCtx, event: E) -> Result<(), HandlerError>;
}