mqtt5-protocol 0.12.0

MQTT v5.0 protocol implementation - packets, encoding, and validation
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

#![cfg_attr(not(feature = "std"), no_std)]
#![warn(clippy::pedantic)]

#[cfg(not(feature = "std"))]
extern crate alloc;

mod prelude;

pub mod bridge;
pub mod connection;
pub mod constants;
pub mod encoding;
pub mod error;
pub mod error_classification;
pub mod flags;
pub mod keepalive;
pub mod numeric;
pub mod packet;
pub mod packet_id;
pub mod protocol;
pub mod qos2;
pub mod quic_error_codes;
pub mod session;
pub mod time;
pub mod topic_matching;
pub mod transport;
pub mod types;
pub mod validation;

pub use error::{MqttError, Result};
pub use flags::{ConnAckFlags, ConnectFlags, PublishFlags};
pub use packet::{FixedHeader, Packet, PacketType};
pub use protocol::v5::properties::{Properties, PropertyId, PropertyValue, PropertyValueType};
pub use protocol::v5::reason_codes::ReasonCode;
pub use transport::Transport;
pub use types::{
    ConnectOptions, ConnectProperties, ConnectResult, Message, MessageProperties, ProtocolVersion,
    PublishOptions, PublishProperties, PublishResult, QoS, RetainHandling, SubscribeOptions,
    WillMessage, WillProperties,
};
pub use validation::{
    is_path_safe_client_id, is_valid_client_id, is_valid_topic_filter, is_valid_topic_name,
    parse_shared_subscription, strip_shared_subscription_prefix, topic_matches_filter,
    validate_client_id, validate_topic_filter, validate_topic_name, RestrictiveValidator,
    StandardValidator, TopicValidator,
};

pub use session::{
    ExpiringMessage, FlowControlConfig, FlowControlStats, LimitsConfig, LimitsManager,
    MessageQueue, QueueResult, QueueStats, QueuedMessage, Subscription, SubscriptionManager,
    TopicAliasManager,
};

pub use connection::{
    ConnectionEvent, ConnectionInfo, ConnectionState, ConnectionStateMachine, DisconnectReason,
    ReconnectConfig,
};

pub use keepalive::{calculate_ping_interval, is_keepalive_timeout, KeepaliveConfig};

pub use error_classification::RecoverableError;

pub use quic_error_codes::{QuicConnectionCode, QuicStreamCode};

pub use numeric::{
    i32_to_u32_saturating, u128_to_f64_saturating, u128_to_u32_saturating, u128_to_u64_saturating,
    u64_to_f64_saturating, u64_to_u16_saturating, u64_to_u32_saturating, u64_to_usize_saturating,
    usize_to_f64_saturating, usize_to_u16_saturating, usize_to_u32_saturating,
    F64_MAX_SAFE_INTEGER,
};

pub use bridge::{
    evaluate_forwarding, BridgeDirection, BridgeStats, ForwardingDecision, TopicMappingCore,
};