Struct EventEmitter 

pub struct EventEmitter { /* private fields */ }

Event emitter for a single node

Handles event creation, policy enforcement, and priority queuing. Events with PropagationMode::Local are stored locally and not queued for transmission.

Implementations

impl EventEmitter

pub fn new(node_id: String, formation_id: String) -> Self

Create a new event emitter for a node

pub fn emit(&self, event: PeatEvent) -> Result<()>

Emit an event with automatic routing based on policy

Events are routed according to their AggregationPolicy:

• PropagationMode::Local: Stored locally, not transmitted
• PropagationMode::Query: Stored locally for query access
• PropagationMode::Summary or Full: Queued for transmission

pub fn emit_new( &self, event_class: EventClass, event_type: String, routing: AggregationPolicy, payload_type_url: String, payload_value: Vec<u8>, source_instance_id: Option<String>, ) -> Result<String>

Create and emit an event with the given parameters

Automatically generates event_id and timestamp.

pub fn emit_product( &self, product_type: &str, payload: Vec<u8>, propagation: PropagationMode, priority: EventPriority, ) -> Result<String>

Emit a product event (output from software processing)

Products are the primary output events from software instances.

pub fn emit_telemetry( &self, metric_name: &str, payload: Vec<u8>, ) -> Result<String>

Emit a telemetry event (metrics, health, diagnostics)

Telemetry defaults to Query propagation (stored locally, queryable)

pub fn emit_anomaly( &self, anomaly_type: &str, payload: Vec<u8>, ) -> Result<String>

Emit an anomaly event (unusual patterns, alerts)

Anomalies default to Full propagation with High priority

pub fn emit_critical( &self, event_type: &str, payload: Vec<u8>, ) -> Result<String>

Emit a critical event (immediate attention required)

Critical events have CRITICAL priority and Full propagation

pub fn pop_critical(&self) -> Vec<PeatEvent>

Pop all critical events for immediate transmission

pub fn pop_events(&self, max_events: usize) -> Vec<PeatEvent>

Pop events for transmission using weighted fair queuing

pub fn has_critical(&self) -> bool

Check if there are critical events pending

pub fn pending_count(&self) -> usize

Get count of pending outbound events

pub fn local_count(&self) -> usize

Get count of locally stored events

pub fn query_local(&self, event_type: Option<&str>) -> Vec<PeatEvent>

Query locally stored events by event type

pub fn get_local(&self, event_id: &str) -> Option<PeatEvent>

Get a specific locally stored event by ID

pub fn node_id(&self) -> &str

Get the node ID

pub fn formation_id(&self) -> &str

Get the formation ID

Trait Implementations

impl Debug for EventEmitter

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

Formats the value using the given formatter.