GatoMQTT 0.2.0

no_std, no_alloc MQTT 3.1.1 broker library for embedded Rust. Bounded session registry, retained messages, QoS 1, transport-agnostic (plain TCP or TLS via TlsSession trait).
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

#![no_std]

#[cfg(test)]
extern crate std;

pub mod codec;
pub mod config;
pub mod handler;
pub mod qos;
pub mod router;
#[path = "session/mod.rs"]
pub mod session;
pub mod tls;
pub mod topics;
pub mod transport;

#[cfg(test)]
mod host_defmt {
    #[no_mangle]
    pub unsafe fn _defmt_acquire() {}

    #[no_mangle]
    pub unsafe fn _defmt_release() {}

    #[no_mangle]
    pub unsafe fn _defmt_flush() {}

    #[no_mangle]
    pub unsafe fn _defmt_write(_bytes: &[u8]) {}

    #[no_mangle]
    pub unsafe fn _defmt_timestamp(_fmt: defmt::Formatter<'_>) {}

    #[no_mangle]
    pub unsafe fn _defmt_panic() -> ! {
        panic!("defmt panic")
    }

    #[no_mangle]
    pub static __DEFMT_MARKER_TRACE_START: u8 = 0;
    #[no_mangle]
    pub static __DEFMT_MARKER_TRACE_END: u8 = 0;
    #[no_mangle]
    pub static __DEFMT_MARKER_DEBUG_START: u8 = 0;
    #[no_mangle]
    pub static __DEFMT_MARKER_DEBUG_END: u8 = 0;
    #[no_mangle]
    pub static __DEFMT_MARKER_INFO_START: u8 = 0;
    #[no_mangle]
    pub static __DEFMT_MARKER_INFO_END: u8 = 0;
    #[no_mangle]
    pub static __DEFMT_MARKER_WARN_START: u8 = 0;
    #[no_mangle]
    pub static __DEFMT_MARKER_WARN_END: u8 = 0;
    #[no_mangle]
    pub static __DEFMT_MARKER_ERROR_START: u8 = 0;
    #[no_mangle]
    pub static __DEFMT_MARKER_ERROR_END: u8 = 0;
}