Struct EventBus 

pub struct EventBus { /* private fields */ }

Broadcast-based event bus.

Implementations

impl EventBus

pub fn new(buffer: usize) -> Self

Create an event bus with a custom broadcast buffer size.

pub fn subscribe(&self) -> Receiver<AmagiEvent>

Subscribe to all future events.

pub fn emit(&self, event: AmagiEvent)

Emit an arbitrary event.

pub fn emit_log<S, I>(&self, level: EventLogLevel, message: S, args: I)

where S: Into<String>, I: IntoIterator, I::Item: Into<String>,

Emit a log event at the requested level.

pub fn emit_http_request( &self, method: impl Into<String>, url: impl Into<String>, )

Emit an outgoing HTTP request event.

pub fn emit_http_response( &self, method: impl Into<String>, url: impl Into<String>, status_code: u16, response_time_ms: u64, )

Emit a completed HTTP response event.

pub fn emit_network_retry( &self, error_code: impl Into<String>, attempt: u32, max_retries: u32, delay_ms: u64, url: Option<String>, )

Emit a retry attempt event.

pub fn emit_network_error( &self, error_code: impl Into<String>, message: impl Into<String>, retries: u32, url: Option<String>, )

Emit a network error event.

pub fn emit_api_success( &self, platform: Platform, method_key: impl Into<String>, status_code: u16, duration_ms: u64, )

Emit an API success event.

pub fn emit_api_error( &self, platform: Platform, method_key: impl Into<String>, error_code: Option<String>, error_message: impl Into<String>, url: Option<String>, duration_ms: Option<u64>, )

Emit an API error event.

Trait Implementations

impl Clone for EventBus

fn clone(&self) -> EventBus

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

Returns the “default value” for a type.