Struct EventBus 

pub struct EventBus { /* private fields */ }

The main event bus for the system

Implementations

impl EventBus

pub fn new() -> Self

Create a new event bus

pub fn subscribe_topology(&self) -> Subscription<TopologyEvent>

Subscribe to topology events

pub async fn publish_topology(&self, event: TopologyEvent) -> Result<()>

Publish a topology event

pub async fn subscribe_dht_key(&self, key: Key) -> Subscription<Bytes>

Subscribe to DHT key watches

pub async fn publish_dht_update(&self, key: Key, value: Bytes) -> Result<()>

Publish a DHT key update

pub async fn subscribe_forwards( &self, identity_key: Key, ) -> Subscription<Forward>

Subscribe to forward announcements for an identity

pub async fn publish_forward_for( &self, identity_key: Key, forward: Forward, ) -> Result<()>

Publish a forward announcement scoped to identity

pub async fn cleanup_expired(&self)

Clean up expired subscriptions

Trait Implementations

impl Default for EventBus

fn default() -> Self

Returns the “default value” for a type.