Struct MqttPlugin 

pub struct MqttPlugin { /* private fields */ }

Implementations

impl MqttPlugin

pub fn new(config: MqttConfig) -> MqttPlugin

pub async fn connect(&mut self) -> Result<(), MqttError>

pub async fn disconnect(&mut self) -> Result<(), MqttError>

pub fn is_connected(&self) -> bool

pub async fn publish( &self, topic: &str, payload: Vec<u8>, qos: QoS, ) -> Result<(), MqttError>

pub async fn publish_retain( &self, topic: &str, payload: Vec<u8>, qos: QoS, ) -> Result<(), MqttError>

pub async fn subscribe(&self, topic: &str, qos: QoS) -> Result<(), MqttError>

pub async fn unsubscribe(&self, topic: &str) -> Result<(), MqttError>

pub fn topic_matches(&self, topic: &str, filter: &str) -> bool

pub async fn message_count(&self) -> usize

pub async fn messages_for(&self, topic: &str) -> Vec<MqttMessage>

pub async fn messages_matching(&self, filter: &str) -> Vec<MqttMessage>

pub async fn subscription_count(&self) -> usize

pub async fn is_subscribed(&self, topic: &str) -> bool

pub async fn subscription_qos(&self, topic: &str) -> Option<QoS>

pub async fn retained_count(&self) -> usize

pub async fn retained_get(&self, topic: &str) -> Option<MqttMessage>

pub async fn clear_messages(&self)