Struct DefaultRouter 

pub struct DefaultRouter {
    pub topics: Arc<RwLock<TopicTree<()>>>,
    pub topics_count: Arc<Counter>,
    pub relations: Arc<AllRelationsMap>,
    pub relations_count: Arc<Counter>,
    /* private fields */
}

Fields

topics: Arc<RwLock<TopicTree<()>>>

topics_count: Arc<Counter>

relations: Arc<AllRelationsMap>

relations_count: Arc<Counter>

Implementations

impl DefaultRouter

pub fn new(scx: Option<ServerContext>) -> DefaultRouter

pub async fn _has_matches(&self, topic: &str) -> Result<bool>

pub async fn _get_routes(&self, topic: &str) -> Result<Vec<Route>>

pub async fn _matches( &self, this_id: Id, topic_name: &TopicName, ) -> Result<SubRelationsMap>

Trait Implementations

impl Clone for DefaultRouter

fn clone(&self) -> DefaultRouter

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Router for DefaultRouter

fn add<'life0, 'life1, 'async_trait>( &'life0 self, topic_filter: &'life1 str, id: Id, opts: SubscriptionOptions, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Id add with topic filter

fn remove<'life0, 'life1, 'async_trait>( &'life0 self, topic_filter: &'life1 str, id: Id, ) -> Pin<Box<dyn Future<Output = Result<bool>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Remove with id topic filter

fn matches<'life0, 'life1, 'async_trait>( &'life0 self, id: Id, topic: &'life1 TopicName, ) -> Pin<Box<dyn Future<Output = Result<SubRelationsMap>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Match with id and topic

fn is_online<'life0, 'life1, 'async_trait>( &'life0 self, node_id: NodeId, client_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = bool> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Check online or offline

fn gets<'life0, 'async_trait>( &'life0 self, limit: usize, ) -> Pin<Box<dyn Future<Output = Vec<Route>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Gets by limit

fn get<'life0, 'life1, 'async_trait>( &'life0 self, topic: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<Route>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Get by topic

fn query_subscriptions<'life0, 'life1, 'async_trait>( &'life0 self, q: &'life1 SubsSearchParams, ) -> Pin<Box<dyn Future<Output = Vec<SubsSearchResult>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

query subscriptions

fn topics_tree<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = usize> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Topics tree

fn topics(&self) -> Counter

Return number of subscribed topics

fn routes(&self) -> Counter

Returns the number of Subscription relationship

fn merge_topics(&self, topics_map: &HashMap<NodeId, Counter>) -> Counter

merge Topics with another

fn merge_routes(&self, routes_map: &HashMap<NodeId, Counter>) -> Counter

merge routes with another

fn list_topics<'life0, 'async_trait>( &'life0 self, top: usize, ) -> Pin<Box<dyn Future<Output = Vec<String>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

get topic tree

fn list_relations<'life0, 'async_trait>( &'life0 self, top: usize, ) -> Pin<Box<dyn Future<Output = Vec<Value>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

get subscription relations

fn relations(&self) -> &AllRelationsMap

all relations