Struct EventBus 

pub struct EventBus<E: DomainEvent> { /* private fields */ }

Generic event bus for publishing and subscribing to domain events

The EventBus provides:

• Type-safe publish/subscribe
• Event envelope with metadata
• Handler registration by event type
• Optional event history for replay

Type Parameters

• E: The domain event type (must implement DomainEvent)

Example

use backbone_messaging::{EventBus, EventBusConfig, DomainEvent};

#[derive(Clone, Debug)]
struct UserCreated { user_id: String }

impl DomainEvent for UserCreated {
    fn event_type(&self) -> &'static str { "UserCreated" }
    fn aggregate_id(&self) -> &str { &self.user_id }
}

let bus = EventBus::<UserCreated>::new();
bus.publish(UserCreated { user_id: "123".into() }).await?;

Implementations

impl<E: DomainEvent> EventBus<E>

pub fn new() -> Self

Create a new event bus with default configuration

pub fn with_config(config: EventBusConfig) -> Self

Create a new event bus with custom configuration

pub async fn publish(&self, event: E) -> Result<(), EventError>

Publish a domain event

pub async fn publish_all(&self, events: Vec<E>) -> Result<(), EventError>

Publish multiple domain events

pub async fn publish_envelope( &self, envelope: EventEnvelope<E>, ) -> Result<(), EventError>

Publish an event envelope (with metadata)

pub async fn register_handler(&self, handler: Arc<dyn EventHandler<E>>)

Register an event handler

pub fn subscribe(&self) -> Receiver<EventEnvelope<E>>

Subscribe to all events (returns a broadcast receiver)

pub async fn history(&self) -> Vec<EventEnvelope<E>>

Get event history (if persistence enabled)

pub async fn events_for_aggregate( &self, aggregate_id: &str, ) -> Vec<EventEnvelope<E>>

Get events for a specific aggregate

pub async fn events_by_type(&self, event_type: &str) -> Vec<EventEnvelope<E>>

Get events by type

pub async fn events_in_range( &self, start: DateTime<Utc>, end: DateTime<Utc>, ) -> Vec<EventEnvelope<E>>

Get events in a time range

pub async fn clear_history(&self)

Clear event history

pub async fn handler_count(&self) -> usize

Get handler count

Trait Implementations

impl<E: DomainEvent> Clone for EventBus<E>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<E: DomainEvent> Default for EventBus<E>

fn default() -> Self

Returns the “default value” for a type.