Struct Broker 

pub struct Broker { /* private fields */ }

Implementations

impl Broker

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

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

Record a presence announcement, keyed by its self-declared pubkey. Prunes expired entries; the announcement is stored verbatim (the bus never inspects it beyond the routing key).

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.