Struct EventRegistry 

pub struct EventRegistry { /* private fields */ }

Registry that dispatches events to all registered sinks.

Errors from individual sinks are logged but do not halt the pipeline — this is the “fire and continue” pattern.

Implementations

impl EventRegistry

pub fn new() -> Self

Create an empty registry.

pub fn register(&mut self, sink: Arc<dyn EventSink>)

Register an event sink.

pub async fn emit(&self, event: &RazeriEvent) -> Vec<(String, EventSinkError)>

Dispatch an event to all sinks.

Errors from individual sinks are collected but do not propagate — all sinks are attempted regardless of failures.

pub fn record(&self, event: RazeriEvent)

Record an event without dispatching it to sinks.

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

Return all recorded events in chronological order.

pub fn recent_events(&self, limit: usize) -> Vec<RazeriEvent>

Return the most recent events in chronological order.

pub fn events_for_workflow(&self, workflow_id: &str) -> Vec<RazeriEvent>

Return events associated with the provided workflow identifier.

pub fn recent_summaries(&self, limit: usize) -> Vec<EventSummary>

Return human-readable summaries for the most recent events.

pub async fn flush_all(&self) -> Vec<(String, EventSinkError)>

Flush all sinks.

pub fn len(&self) -> usize

Number of registered sinks.

pub fn is_empty(&self) -> bool

Whether the registry has no sinks.

pub fn query(&self, q: &EventQuery) -> Vec<RazeriEvent>

Execute a flexible query against the recorded event history.

Trait Implementations

impl Default for EventRegistry

fn default() -> Self

Returns the “default value” for a type.

impl EventEmitter for EventRegistry

fn emit_event<'life0, 'async_trait>( &'life0 self, event: RazeriEvent, ) -> Pin<Box<dyn Future<Output = Vec<(String, EventSinkError)>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Emit a canonical event into the monitoring pipeline.