Enum Packet 

pub enum Packet {
    Connect(Connect),
    ConnAck(ConnAck),
    Publish(Publish),
    PubAck(PubAck),
    PubRec(PubRec),
    PubRel(PubRel),
    PubComp(PubComp),
    Subscribe(Subscribe),
    SubAck(SubAck),
    Unsubscribe(Unsubscribe),
    UnsubAck(UnsubAck),
    PingReq(PingReq),
    PingResp(PingResp),
    Disconnect(Disconnect),
}

Represents all possible MQTT v3.x packet types

This enum serves as the main abstraction for working with MQTT packets, providing a unified interface for packet handling while maintaining type safety for each specific packet type.

Example

use std::time::Duration;
use mqute_codec::protocol::v4::{Packet, Connect};
use bytes::{Bytes, BytesMut};

let connect = Connect::new(
    "client",
    None,
    None,
    Duration::from_secs(30),
    true);

let mut buf = BytesMut::new();
let packet = Packet::Connect(connect);

packet.encode(&mut buf).unwrap()

Variants

Connect(Connect)

Client-initiated connection request. First packet in connection establishment flow

ConnAck(ConnAck)

Server connection acknowledgment. Sent in response to CONNECT packet

Publish(Publish)

Message publication. Primary message delivery mechanism.

PubAck(PubAck)

QoS 1 publication acknowledgment. Acknowledges receipt of QoS 1 messages

PubRec(PubRec)

QoS 2 publication received (part 1). First packet in QoS 2 protocol flow

PubRel(PubRel)

QoS 2 publication release (part 2). Second packet in QoS 2 protocol flow

PubComp(PubComp)

QoS 2 publication complete (part 3). Final packet in QoS 2 protocol flow

Subscribe(Subscribe)

Subscription request. Begins subscription creation/modification

SubAck(SubAck)

Subscription acknowledgment. Confirms subscription processing results

Unsubscribe(Unsubscribe)

Unsubscription request. Begins subscription termination

UnsubAck(UnsubAck)

Unsubscription acknowledgment. Confirms unsubscription processing

PingReq(PingReq)

Keep-alive ping request. Must be responded to with PINGRESP

PingResp(PingResp)

Keep-alive ping response. Sent in response to PINGREQ to confirm connection is active

Disconnect(Disconnect)

Graceful connection termination. Properly closes the MQTT connection

Implementations

impl Packet

pub fn decode(raw_packet: RawPacket) -> Result<Self, Error>

Decodes a raw MQTT packet into the appropriate Packet variant

This is the primary entry point for packet processing, handling:

• Packet type identification
• Payload validation
• Special cases for empty payload packets
• Delegation to specific packet decoders

pub fn encode(&self, buf: &mut BytesMut) -> Result<(), Error>

Encodes the packet into its wire format

Delegates to the specific packet implementation’s encoder while providing a unified interface for all packet types.

Trait Implementations

impl Clone for Packet

fn clone(&self) -> Packet

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Packet

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

Formats the value using the given formatter.

impl From<ConnAck> for Packet

fn from(value: ConnAck) -> Self

Converts to this type from the input type.

impl From<Connect> for Packet

fn from(value: Connect) -> Self

Converts to this type from the input type.

impl From<Disconnect> for Packet

fn from(value: Disconnect) -> Self

Converts to this type from the input type.

impl From<PingReq> for Packet

fn from(value: PingReq) -> Self

Converts to this type from the input type.

impl From<PingResp> for Packet

fn from(value: PingResp) -> Self

Converts to this type from the input type.

impl From<PubAck> for Packet

fn from(value: PubAck) -> Self

Converts to this type from the input type.

impl From<PubComp> for Packet

fn from(value: PubComp) -> Self

Converts to this type from the input type.

impl From<PubRec> for Packet

fn from(value: PubRec) -> Self

Converts to this type from the input type.

impl From<PubRel> for Packet

fn from(value: PubRel) -> Self

Converts to this type from the input type.

impl From<Publish> for Packet

fn from(value: Publish) -> Self

Converts to this type from the input type.

impl From<SubAck> for Packet

fn from(value: SubAck) -> Self

Converts to this type from the input type.

impl From<Subscribe> for Packet

fn from(value: Subscribe) -> Self

Converts to this type from the input type.

impl From<UnsubAck> for Packet

fn from(value: UnsubAck) -> Self

Converts to this type from the input type.

impl From<Unsubscribe> for Packet

fn from(value: Unsubscribe) -> Self

Converts to this type from the input type.

impl PartialEq for Packet

fn eq(&self, other: &Packet) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Eq for Packet

impl StructuralPartialEq for Packet