Enum ntex_mqtt::v3::codec::Packet[−][src]

pub enum Packet {
    Connect(Connect),
    ConnectAck {
        session_present: bool,
        return_code: ConnectAckReason,
    },
    Publish(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(Connect)

Client request to connect to Server

ConnectAck

Connect acknowledgment

Fields of ConnectAck

session_present: bool

enables a Client to establish whether the Client and Server have a consistent view about whether there is already stored Session state.

return_code: ConnectAckReason

Publish(Publish)

Publish message

PublishAck

Publish acknowledgment

Fields of PublishAck

packet_id: NonZeroU16

Packet Identifier

PublishReceived

Publish received (assured delivery part 1)

Fields of PublishReceived

packet_id: NonZeroU16

Packet Identifier

PublishRelease

Publish release (assured delivery part 2)

Fields of PublishRelease

packet_id: NonZeroU16

Packet Identifier

PublishComplete

Publish complete (assured delivery part 3)

Fields of PublishComplete

packet_id: NonZeroU16

Packet Identifier

Subscribe

Client subscribe request

SubscribeAck

Subscribe acknowledgment

Fields of SubscribeAck

packet_id: NonZeroU16status: Vec<SubscribeReturnCode>

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

Unsubscribe

Unsubscribe request

Fields of Unsubscribe

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 of UnsubscribeAck

packet_id: NonZeroU16

Packet Identifier

PingRequest

PING request

PingResponse

PING response

Disconnect

Client is disconnecting

Implementations

`impl Packet`[src]

`pub fn packet_type(&self) -> u8`[src]

Trait Implementations

`impl Clone for Packet`[src]

`fn clone(&self) -> Packet`[src]

`pub fn clone_from(&mut self, source: &Self)`1.0.0[src]

`impl Debug for Packet`[src]

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

`impl From<Connect> for Packet`[src]

`fn from(val: Connect) -> Packet`[src]

`impl From<Publish> for Packet`[src]

`fn from(val: Publish) -> Packet`[src]

`impl PartialEq<Packet> for Packet`[src]

`fn eq(&self, other: &Packet) -> bool`[src]

`fn ne(&self, other: &Packet) -> bool`[src]

`impl StructuralPartialEq for Packet`[src]

Auto Trait Implementations

`impl RefUnwindSafe for Packet`

`impl Send for Packet`

`impl Sync for Packet`

`impl Unpin for Packet`

`impl UnwindSafe for Packet`

Blanket Implementations

`impl<T> Any for T where T: 'static + ?Sized,` [src]

`pub fn type_id(&self) -> TypeId`[src]

`impl<T> Borrow<T> for T where T: ?Sized,` [src]

`pub fn borrow(&self) -> &T`[src]

`impl<T> BorrowMut<T> for T where T: ?Sized,` [src]

`pub fn borrow_mut(&mut self) -> &mut T`[src]

`impl<T> From<T> for T`[src]

`pub fn from(t: T) -> T`[src]

`impl<T> Instrument for T`[src]

`pub fn instrument(self, span: Span) -> Instrumented<Self>`[src]

`pub fn in_current_span(self) -> Instrumented<Self>`[src]

`impl<T> Instrument for T`[src]

`pub fn instrument(self, span: Span) -> Instrumented<Self>`[src]

`pub fn in_current_span(self) -> Instrumented<Self>`[src]

`impl<T, U> Into for T where U: From<T>,` [src]

`pub fn into(self) -> U`[src]

`impl<T> Same<T> for T`

`type Output = T`

Should always be Self

`impl<T> ToOwned for T where T: Clone,` [src]

`type Owned = T`

The resulting type after obtaining ownership.

`pub fn to_owned(&self) -> T`[src]

`pub fn clone_into(&self, target: &mut T)`[src]

`impl<T, U> TryFrom for T where U: Into<T>,` [src]

`type Error = Infallible`

The type returned in the event of a conversion error.

`pub fn try_from(value: U) -> Result<T, <T as TryFrom>::Error>`[src]

`impl<T, U> TryInto for T where U: TryFrom<T>,` [src]

`type Error = >::Error`

The type returned in the event of a conversion error.

Enum ntex_mqtt::v3::codec::Packet[−][src]

Variants

Fields of ConnectAck

Fields of PublishAck

Fields of PublishReceived

Fields of PublishRelease

Fields of PublishComplete

Fields of Subscribe

Fields of SubscribeAck

Fields of Unsubscribe

Fields of UnsubscribeAck

Implementations

impl Packet[src]

pub fn packet_type(&self) -> u8[src]

Trait Implementations

impl Clone for Packet[src]

fn clone(&self) -> Packet[src]

pub fn clone_from(&mut self, source: &Self)1.0.0[src]

impl Debug for Packet[src]

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

impl From<Connect> for Packet[src]

fn from(val: Connect) -> Packet[src]

impl From<Publish> for Packet[src]

fn from(val: Publish) -> Packet[src]

impl PartialEq<Packet> for Packet[src]

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

fn ne(&self, other: &Packet) -> bool[src]

impl StructuralPartialEq for Packet[src]

Auto Trait Implementations

impl RefUnwindSafe for Packet

impl Send for Packet

impl Sync for Packet

impl Unpin for Packet

impl UnwindSafe for Packet

Blanket Implementations

impl<T> Any for T where T: 'static + ?Sized, [src]

pub fn type_id(&self) -> TypeId[src]

impl<T> Borrow<T> for T where T: ?Sized, [src]

pub fn borrow(&self) -> &T[src]

impl<T> BorrowMut<T> for T where T: ?Sized, [src]

pub fn borrow_mut(&mut self) -> &mut T[src]

impl<T> From<T> for T[src]

pub fn from(t: T) -> T[src]

impl<T> Instrument for T[src]

pub fn instrument(self, span: Span) -> Instrumented<Self>[src]

pub fn in_current_span(self) -> Instrumented<Self>[src]

impl<T> Instrument for T[src]

pub fn instrument(self, span: Span) -> Instrumented<Self>[src]

pub fn in_current_span(self) -> Instrumented<Self>[src]

impl<T, U> Into<U> for T where U: From<T>, [src]

pub fn into(self) -> U[src]

impl<T> Same<T> for T

type Output = T

impl<T> ToOwned for T where T: Clone, [src]

type Owned = T

pub fn to_owned(&self) -> T[src]

pub fn clone_into(&self, target: &mut T)[src]

impl<T, U> TryFrom<U> for T where U: Into<T>, [src]

type Error = Infallible

pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>[src]

impl<T, U> TryInto<U> for T where U: TryFrom<T>, [src]

type Error = <U as TryFrom<T>>::Error

pub fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>[src]

impl<V, T> VZip<V> for T where V: MultiLane<T>,

pub fn vzip(self) -> V

`impl Packet`[src]

`pub fn packet_type(&self) -> u8`[src]

`impl Clone for Packet`[src]

`fn clone(&self) -> Packet`[src]

`pub fn clone_from(&mut self, source: &Self)`1.0.0[src]

`impl Debug for Packet`[src]

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

`impl From<Connect> for Packet`[src]

`fn from(val: Connect) -> Packet`[src]

`impl From<Publish> for Packet`[src]

`fn from(val: Publish) -> Packet`[src]

`impl PartialEq<Packet> for Packet`[src]

`fn eq(&self, other: &Packet) -> bool`[src]

`fn ne(&self, other: &Packet) -> bool`[src]

`impl StructuralPartialEq for Packet`[src]

`impl RefUnwindSafe for Packet`

`impl Send for Packet`

`impl Sync for Packet`

`impl Unpin for Packet`

`impl UnwindSafe for Packet`

`impl<T> Any for T where T: 'static + ?Sized,` [src]

`pub fn type_id(&self) -> TypeId`[src]

`impl<T> Borrow<T> for T where T: ?Sized,` [src]

`pub fn borrow(&self) -> &T`[src]

`impl<T> BorrowMut<T> for T where T: ?Sized,` [src]

`pub fn borrow_mut(&mut self) -> &mut T`[src]

`impl<T> From<T> for T`[src]

`pub fn from(t: T) -> T`[src]

`impl<T> Instrument for T`[src]

`pub fn instrument(self, span: Span) -> Instrumented<Self>`[src]

`pub fn in_current_span(self) -> Instrumented<Self>`[src]

`impl<T> Instrument for T`[src]

`pub fn instrument(self, span: Span) -> Instrumented<Self>`[src]

`pub fn in_current_span(self) -> Instrumented<Self>`[src]

`impl<T, U> Into<U> for T where U: From<T>,` [src]

`pub fn into(self) -> U`[src]

`impl<T> Same<T> for T`

`type Output = T`

`impl<T> ToOwned for T where T: Clone,` [src]

`type Owned = T`

`pub fn to_owned(&self) -> T`[src]

`pub fn clone_into(&self, target: &mut T)`[src]

`impl<T, U> TryFrom<U> for T where U: Into<T>,` [src]

`type Error = Infallible`

`pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>`[src]

`impl<T, U> TryInto<U> for T where U: TryFrom<T>,` [src]

`type Error = <U as TryFrom<T>>::Error`

`pub fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>`[src]

`impl<V, T> VZip<V> for T where V: MultiLane<T>,`

`pub fn vzip(self) -> V`