Struct TopicTree 

pub struct TopicTree { /* private fields */ }

Topic tree for managing subscriptions and retained messages

Implementations

impl TopicTree

pub fn new() -> Self

pub fn match_topic(&self, topic: &str) -> Vec<&Subscription>

Match a topic against all subscriptions

pub fn subscribe(&mut self, filter: &str, qos: u8, client_id: &str)

Add a subscription

pub fn unsubscribe(&mut self, filter: &str, client_id: &str)

Remove a subscription

pub fn retain_message(&mut self, topic: &str, payload: Vec<u8>, qos: u8)

Store a retained message

pub fn get_retained(&self, topic: &str) -> Option<&RetainedMessage>

Get retained message for a topic

pub fn get_retained_for_filter( &self, filter: &str, ) -> Vec<(&str, &RetainedMessage)>

Get all retained messages that match a subscription filter

pub fn cleanup_expired_retained(&mut self, max_age_secs: u64)

Clean up expired retained messages (basic implementation)

pub fn get_all_topic_filters(&self) -> Vec<String>

Get all topic filters (subscription patterns)

pub fn get_all_retained_topics(&self) -> Vec<String>

Get all retained message topics

pub fn stats(&self) -> TopicStats

Get topic statistics

Trait Implementations

impl Default for TopicTree

fn default() -> Self

Returns the “default value” for a type.