rmqtt 0.20.0

MQTT Server for v3.1, v3.1.1 and v5.0 protocols
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
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130

//! MQTT Broker Performance Monitoring System
//!
//! Provides comprehensive metrics collection with:
//! - 50+ operational metrics
//! - Thread-safe atomic counters
//! - Categorized event tracking
//! - Serialization support
//!
//! ## Metric Categories
//! 1. ​**​Client Lifecycle​**​:
//!    - Authentication attempts/successes
//!    - Connection establishment
//!    - Subscription management
//!    - ACL verification
//!
//! 2. ​**​Session Tracking​**​:
//!    - Creation/resumption
//!    - Subscription changes
//!    - Termination events
//!
//! 3. ​**​Message Processing​**​:
//!    - Publish/delivery/ack flows
//!    - Message drops
//!    - Non-subscribed messages
//!    - QoS-specific tracking
//!
//! 4. ​**​Message Types​**​:
//!    - Custom messages
//!    - Admin messages  
//!    - Last Will messages
//!    - System messages
//!    - Bridge messages
//!    - Retained messages
//!
//! ## Key Features
//! - Atomic counters for thread safety
//! - Automatic derive macros for metrics operations
//! - Serde serialization support
//! - Zero-overhead when disabled
//! - Categorized counters for detailed analysis
//!
//! ## Implementation Details
//! - Uses AtomicUsize for lock-free counting
//! - Macro-generated metric operations
//! - Organized by logical categories
//! - Designed for monitoring systems integration
//!
//! Usage Patterns:
//! 1. Increment counters at relevant code points
//! 2. Serialize for external monitoring
//! 3. Analyze trends across metric categories
//!
//! Note: All metrics are optional - only enabled counters
//! incur measurement overhead.

use std::sync::atomic::{AtomicUsize, Ordering};

use serde::{Deserialize, Serialize};

use crate::macros::Metrics;

#[derive(Serialize, Deserialize, Debug, Default, Metrics)]
pub struct Metrics {
    client_authenticate: AtomicUsize,
    client_auth_anonymous: AtomicUsize,
    client_auth_anonymous_error: AtomicUsize,
    client_handshaking_timeout: AtomicUsize,
    client_connect: AtomicUsize,
    client_connack: AtomicUsize,
    client_connack_auth_error: AtomicUsize,
    client_connack_unavailable_error: AtomicUsize,
    client_connack_error: AtomicUsize,
    client_connected: AtomicUsize,
    client_disconnected: AtomicUsize,
    client_subscribe_check_acl: AtomicUsize,
    client_publish_check_acl: AtomicUsize,
    client_subscribe: AtomicUsize,
    client_unsubscribe: AtomicUsize,
    client_subscribe_error: AtomicUsize,
    client_subscribe_auth_error: AtomicUsize,
    client_publish_auth_error: AtomicUsize,
    client_publish_error: AtomicUsize,

    session_subscribed: AtomicUsize,
    session_unsubscribed: AtomicUsize,
    session_created: AtomicUsize,
    session_resumed: AtomicUsize,
    session_terminated: AtomicUsize,

    messages_publish: AtomicUsize,
    // messages_received: AtomicUsize,
    // messages_received_qos0: AtomicUsize,
    // messages_received_qos1: AtomicUsize,
    // messages_received_qos2: AtomicUsize,
    messages_delivered: AtomicUsize,
    // messages_forward: AtomicUsize,
    // messages_sent: AtomicUsize,
    messages_acked: AtomicUsize,
    messages_dropped: AtomicUsize,

    messages_publish_custom: AtomicUsize,
    messages_delivered_custom: AtomicUsize,
    messages_acked_custom: AtomicUsize,

    messages_publish_admin: AtomicUsize,
    messages_delivered_admin: AtomicUsize,
    messages_acked_admin: AtomicUsize,

    messages_publish_lastwill: AtomicUsize,
    messages_delivered_lastwill: AtomicUsize,
    messages_acked_lastwill: AtomicUsize,

    messages_publish_system: AtomicUsize,
    messages_delivered_system: AtomicUsize,
    messages_acked_system: AtomicUsize,

    messages_publish_bridge: AtomicUsize,
    messages_delivered_bridge: AtomicUsize,
    messages_acked_bridge: AtomicUsize,

    messages_delivered_retain: AtomicUsize,
    messages_acked_retain: AtomicUsize,

    messages_nonsubscribed: AtomicUsize,
    messages_nonsubscribed_custom: AtomicUsize,
    messages_nonsubscribed_admin: AtomicUsize,
    messages_nonsubscribed_lastwill: AtomicUsize,
    messages_nonsubscribed_system: AtomicUsize,
    messages_nonsubscribed_bridge: AtomicUsize,
}