Enum Packet 

pub enum Packet {
    Connect(Box<Connect>),
    ConnectAck(ConnectAck),
    Publish(Box<Publish>),
    PublishAck {
        packet_id: NonZeroU16,
    },
    PublishReceived {
        packet_id: NonZeroU16,
    },
    PublishRelease {
        packet_id: NonZeroU16,
    },
    PublishComplete {
        packet_id: NonZeroU16,
    },
    Subscribe {
        packet_id: NonZeroU16,
        topic_filters: Vec<(ByteString, QoS)>,
    },
    SubscribeAck {
        packet_id: NonZeroU16,
        status: Vec<SubscribeReturnCode>,
    },
    Unsubscribe {
        packet_id: NonZeroU16,
        topic_filters: Vec<ByteString>,
    },
    UnsubscribeAck {
        packet_id: NonZeroU16,
    },
    PingRequest,
    PingResponse,
    Disconnect,
}

MQTT Control Packets

Variants

Connect(Box<Connect>)

Client request to connect to Server

ConnectAck(ConnectAck)

Connect acknowledgment

Publish(Box<Publish>)

Publish message

PublishAck

Publish acknowledgment

Fields

packet_id: NonZeroU16

Packet Identifier

PublishReceived

Publish received (assured delivery part 1)

Fields

packet_id: NonZeroU16

Packet Identifier

PublishRelease

Publish release (assured delivery part 2)

Fields

packet_id: NonZeroU16

Packet Identifier

PublishComplete

Publish complete (assured delivery part 3)

Fields

packet_id: NonZeroU16

Packet Identifier

Subscribe

Client subscribe request

Fields

packet_id: NonZeroU16

Packet Identifier

topic_filters: Vec<(ByteString, QoS)>

the list of Topic Filters and QoS to which the Client wants to subscribe.

SubscribeAck

Subscribe acknowledgment

Fields

packet_id: NonZeroU16

status: Vec<SubscribeReturnCode>

corresponds to a Topic Filter in the SUBSCRIBE Packet being acknowledged.

Unsubscribe

Unsubscribe request

Fields

packet_id: NonZeroU16

Packet Identifier

topic_filters: Vec<ByteString>

the list of Topic Filters that the Client wishes to unsubscribe from.

UnsubscribeAck

Unsubscribe acknowledgment

Fields

packet_id: NonZeroU16

Packet Identifier

PingRequest

PING request

PingResponse

PING response

Disconnect

Client is disconnecting

Implementations

impl Packet

pub fn packet_type(&self) -> u8

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 Encoder<Packet> for Codec

type Error = EncodeError

The type of encoding errors.

fn encode( &mut self, item: Packet, dst: &mut BytesMut, ) -> Result<(), EncodeError>

Encodes a frame into the buffer provided.

impl From<Connect> for Packet

fn from(val: Connect) -> Packet

Converts to this type from the input type.

impl From<Publish> for Packet

fn from(val: Publish) -> Packet

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