Struct EventBus 

pub struct EventBus { /* private fields */ }

Event Bus - Central publish/subscribe system

Implementations

impl EventBus

pub fn new() -> Self

Creates new event bus

pub fn subscribe( &self, event_type: EventType, handler_id: impl Into<String>, handler: EventHandler, )

Subscribes to an event type

pub fn unsubscribe(&self, event_type: &EventType, handler_id: &str)

Unsubscribes from an event type

pub fn publish(&self, event: Event)

Publishes event to all subscribers

pub fn subscriber_count(&self, event_type: &EventType) -> usize

Gets subscriber count for event type

pub fn get_history(&self, event_type: &EventType) -> Vec<Event>

Gets event history for type

pub fn total_events(&self) -> u64

Gets total event count

pub fn clear_history(&self)

Clears event history

pub fn get_all_events(&self) -> Vec<Event>

Gets all events

pub fn get_events_by_correlation(&self, correlation_id: &str) -> Vec<Event>

Gets all events for a specific correlation ID (scan)

pub fn get_events_by_correlation_and_time( &self, correlation_id: &str, start_ms: u64, end_ms: u64, ) -> Vec<Event>

Gets events for correlation ID within time range (ms)

pub fn get_events_sorted(&self) -> Vec<Event>

Gets all events sorted by timestamp

Trait Implementations

impl Default for EventBus

fn default() -> Self

Returns the “default value” for a type.