Enum MqttPacket

pub enum MqttPacket {
    V3(Packet),
    V5(Packet),
    Version(ProtocolVersion),
}

Decoded MQTT protocol packets

Represents all possible packet types across supported protocol versions plus version detection results during handshake

Variants

V3(Packet)

MQTT v3.1.1 protocol packet

V5(Packet)

MQTT v5.0 protocol packet

Version(ProtocolVersion)

Protocol version detection result

Trait Implementations

impl Debug for MqttPacket

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Encoder<MqttPacket> for MqttCodec

fn encode( &mut self, item: MqttPacket, dst: &mut BytesMut, ) -> Result<(), Self::Error>

Encodes MQTT packets according to active protocol version

Example

use bytes::BytesMut;
use rmqtt_codec::{MqttCodec, MqttPacket, v3};
use tokio_util::codec::Encoder;

let mut codec = MqttCodec::V3(v3::Codec::new(1024*1024));
let mut buffer = BytesMut::new();
let packet = MqttPacket::V3(v3::Packet::PingRequest);
codec.encode(packet, &mut buffer).unwrap();

type Error = EncodeError

The type of encoding errors.