Expand description
This module is the place where all the protocol specifics gets abstracted out and creates a structures which are common across protocols. Since, MQTT is the core protocol that this broker supports, a lot of structs closely map to what MQTT specifies in its protocol
Structs§
- Acknowledgement to connect packet
- Connection packet initiated by the client
- Subscription filter
- Packet type from a byte
- LastWill that broker forwards on behalf of the client
- Acknowledgement to QoS1 publish
- QoS2 Assured publish complete, in response to PUBREL packet
- Acknowledgement to QoS1 publish
- QoS2 Publish release, in response to PUBREC packet
- Publish packet
- Acknowledgement to subscribe
- Subscription packet
- Acknowledgement to unsubscribe
- Unsubscribe packet
Enums§
- Return code in connack
- MQTT packet type
- Return code in puback
- Return code in PubComp
- Return code in PubRec
- Return code in PubRel
Functions§
- Checks if the stream has enough bytes to frame a packet and returns fixed header only if a packet can be framed with existing bytes in the
stream. The passed stream doesn’t modify parent stream’s cursor. If this function returned an error, nextcheckon the same parent stream is forced start with cursor at 0 again (Iter is owned. Only Iter’s cursor is changed internally)