Struct EventRegistry 

pub struct EventRegistry { /* private fields */ }

Registry that dispatches events to all registered sinks.

emit hands an event to each sink one after another, in the order the sinks were registered, and every sink has the event before emit returns, so each sink receives every event in the order it was emitted. A sink that refuses an event does not stop the sinks after it: its refusal is returned with its name. A sink that is slow holds up the sinks after it, so a sink that sends events over a network hands them to a queue of its own and returns.

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)>

Record an event, then hand it to every sink, one after another in the order they were registered.

Returns each sink’s refusal with the sink’s name; a refusal does not stop the sinks after it.

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 sink_names(&self) -> Vec<String>

The names of the sinks this registry dispatches to, in the order they were registered.

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.