Struct Router 

pub struct Router {
    entries: Vec<RouterEntry>,
    supports_sub_id: AtomicBool,
    subscribe_timeout: Duration,
}

Fields

entries: Vec<RouterEntry>

supports_sub_id: AtomicBool

subscribe_timeout: Duration

Implementations

impl Router

pub(crate) fn new(subscribe_timeout: Duration) -> Self

pub(crate) fn stat_entries(&self) -> (usize, usize)

Report (active, total) count of entries for the health report.

pub(crate) fn add_subscription( &mut self, template: SubscriptionTemplate, ) -> SubscriptionId

fn iter( &self, inactive_only: bool, ) -> impl Iterator<Item = (SubscriptionId, &RouterEntry)>

fn get_by_sub_id(&self, sub_id: SubscriptionId) -> Option<&RouterEntry>

pub(crate) fn route(&self, msg: Message)

fn naive_route(&self, msg: Message)

pub(crate) async fn try_activate_subscription_by_id( &self, paho_client: &AsyncClient, sub_id: SubscriptionId, ) -> Result<(), Error>

pub(crate) async fn on_connected( &self, paho_client: &AsyncClient, info: &ConnectInfo, cancel_fut: impl Future<Output = ()>, ) -> bool