Struct EventsClient 

pub struct EventsClient { /* private fields */ }

ctx.events — the event bus facade.

Implementations

impl EventsClient

pub async fn publish( &self, topic: &str, payload: Value, ) -> Result<i64, ClientError>

Publish a payload on a topic. Returns the delivered count.

pub async fn subscribe( &self, topic_pattern: &str, callback: EventCallback, ) -> Result<(), ClientError>

Subscribe to a topic pattern; the callback fires for each matched delivery with the event’s args map (topic, payload, publisher, timestamp_ms).

Trait Implementations

impl Clone for EventsClient

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.