Struct EventBus 

pub struct EventBus { /* private fields */ }

Bounded process-local store of recently emitted Runtime events.

Implementations

impl EventBus

pub fn new() -> Self

Creates an empty event bus.

pub fn attach_journal(&self, journal: Arc<FileOperationalJournal>)

Attaches a durable journal and loads its retained event envelopes.

pub fn durability_error(&self) -> Option<String>

Returns the last durable journal failure, when persistence degraded.

pub fn emit(&self, event: EventEnvelope)

Appends one event and evicts the oldest item at the configured bound.

pub fn emit_many(&self, events: Vec<EventEnvelope>)

Appends multiple events and retains at most 10,000 recent items.

pub fn len(&self) -> usize

Returns the current number of retained events.

pub fn is_empty(&self) -> bool

Reports whether no events are retained.

pub fn events(&self) -> Vec<EventEnvelope>

Returns a point-in-time copy of retained events.

pub fn clear(&self)

Removes all retained events.

Trait Implementations

impl Clone for EventBus

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for EventBus

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

Formats the value using the given formatter.

impl Default for EventBus

fn default() -> EventBus

Returns the “default value” for a type.