Struct Broker 

pub struct Broker { /* private fields */ }

Implementations

impl Broker

pub fn new(store: Store, cap: usize) -> Self

pub fn announce(&self, key: String, announcement: Value, now: u64)

Record a presence announcement under a per-session key (pubkey#session_id, or a bare pubkey for a sessionless legacy announcement). Prunes expired entries; the announcement is stored verbatim (the bus never inspects it beyond the routing key).

pub fn unregister(&self, key: &str)

Immediately drop a session’s presence (a graceful close), so a peer learns it’s really gone rather than waiting out the TTL. Unsigned and best-effort: the bus verifies nothing, and a still-live session simply re-announces on its next heartbeat, so a spurious unregister is self-healing.

pub fn roster(&self, now: u64) -> Vec<Value>

The live (non-expired) announcements.

pub async fn enqueue(&self, to: &str, payload: Value, ts: u64) -> Result<()>

Enqueue for to: persist, enforce the cap (drop oldest), wake a waiter.

pub async fn recv( &self, id: &str, wait: Duration, ) -> Result<Option<(Envelope, String)>>

Wait up to wait for the oldest un-acked message for id. Returns the envelope and its ack key; the message stays in the store until ack.

pub async fn ack(&self, key: &str) -> Result<()>

pub async fn depth(&self, id: &str) -> Result<usize>

pub fn router(self) -> Router

Trait Implementations

impl Clone for Broker

fn clone(&self) -> Broker

Returns a duplicate of the value.

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

Performs copy-assignment from source.