Struct MessageBus 

pub struct MessageBus { /* private fields */ }

The kernel-internal message bus.

MessageBus is cheaply cloneable; clones share the same underlying state and can be handed out to modules and subsystems freely.

Implementations

impl MessageBus

pub fn new() -> Self

Construct a new, empty bus.

pub async fn grant_capability(&self, cap: Capability)

Grant a capability token. After this call, any source holding cap may call Self::publish_with_capability successfully.

pub async fn revoke_capability(&self, cap: &Capability)

Revoke a previously granted capability.

pub async fn publish_with_capability( &self, envelope: Envelope, cap: &Capability, ) -> Result<()>

Publish an Envelope only if cap has been granted.

Returns KernelError::Denied if the capability is not in the grant set. On success, routes the envelope identically to Self::publish.

pub async fn subscribe(&self) -> Subscription

Register a new subscriber and return a Subscription handle.

pub async fn publish(&self, envelope: Envelope) -> Result<()>

Publish an Envelope to every subscriber.

Subscribers whose channels are closed are silently dropped. If a subscriber’s channel is full the message is dropped for that subscriber only and a warning is traced; this prevents one slow subscriber from blocking the whole bus.

pub async fn send_command( &self, source: impl Into<String>, command: Command, ) -> Result<Uuid>

Convenience helper: wrap a Command in an Envelope and publish it.

pub async fn emit_event( &self, source: impl Into<String>, event: Event, ) -> Result<Uuid>

Convenience helper: wrap an Event in an Envelope and publish it.

pub async fn subscriber_count(&self) -> usize

Returns the number of live subscribers (best-effort).

Trait Implementations

impl Clone for MessageBus

fn clone(&self) -> MessageBus

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MessageBus

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

Formats the value using the given formatter.

impl Default for MessageBus

fn default() -> MessageBus

Returns the “default value” for a type.