mqtt5 0.31.2

Complete MQTT v5.0 platform with high-performance async client and full-featured broker supporting TCP, TLS, WebSocket, authentication, bridging, and resource monitoring
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71

//! MQTT Broker-to-Broker Bridge Implementation
//!
//! Enables connecting multiple MQTT brokers together by having one broker
//! act as a client to another broker, with configurable topic mapping and
//! message flow direction.

pub mod config;
pub mod connection;
pub mod loop_prevention;
pub mod manager;

pub use config::{BridgeConfig, BridgeDirection, BridgeProtocol, TopicMapping};
pub use connection::{BridgeConnection, ConnectedBroker};
pub use loop_prevention::LoopPrevention;
pub use manager::BridgeManager;

use crate::time::Instant;

/// Statistics for a bridge connection
#[derive(Debug, Clone, Default)]
pub struct BridgeStats {
    /// Whether the bridge is currently connected
    pub connected: bool,
    /// Number of connection attempts
    pub connection_attempts: u64,
    /// Messages sent to remote broker
    pub messages_sent: u64,
    /// Messages received from remote broker
    pub messages_received: u64,
    /// Bytes sent to remote broker
    pub bytes_sent: u64,
    /// Bytes received from remote broker
    pub bytes_received: u64,
    /// Last error message if any
    pub last_error: Option<String>,
    /// Time when connection was established
    pub connected_since: Option<Instant>,
    /// Current broker address we're connected to
    pub current_broker: Option<String>,
    /// Whether we're connected to the primary broker
    pub on_primary: bool,
    /// Number of failback attempts to primary
    pub failback_attempts: u64,
}

/// Result type for bridge operations
pub type Result<T> = std::result::Result<T, BridgeError>;

/// Bridge-specific errors
#[derive(Debug, thiserror::Error)]
pub enum BridgeError {
    /// Connection to remote broker failed
    #[error("Connection failed: {0}")]
    ConnectionFailed(String),

    /// Configuration error
    #[error("Configuration error: {0}")]
    ConfigurationError(String),

    /// Topic mapping error
    #[error("Topic mapping error: {0}")]
    TopicMappingError(String),

    /// Message loop detected
    #[error("Message loop detected for topic: {0}")]
    LoopDetected(String),

    /// Client error
    #[error("Client error: {0}")]
    ClientError(#[from] crate::error::MqttError),
}