Enum ntex_mqtt::v3::codec::Packet [−][src]
pub enum Packet {}Show variants
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,
Expand description
MQTT Control Packets
Variants
Connect(Connect)
Expand description
Client request to connect to Server
Expand description
Connect acknowledgment
Show fields
Fields of ConnectAck
session_present: bool
Expand description
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)
Expand description
Publish message
Expand description
Publish acknowledgment
Show fields
Fields of PublishAck
packet_id: NonZeroU16
Expand description
Packet Identifier
Expand description
Publish received (assured delivery part 1)
Show fields
Fields of PublishReceived
packet_id: NonZeroU16
Expand description
Packet Identifier
Expand description
Publish release (assured delivery part 2)
Show fields
Fields of PublishRelease
packet_id: NonZeroU16
Expand description
Packet Identifier
Expand description
Publish complete (assured delivery part 3)
Show fields
Fields of PublishComplete
packet_id: NonZeroU16
Expand description
Packet Identifier
Expand description
Client subscribe request
Show fields
Fields of Subscribe
packet_id: NonZeroU16
Expand description
Packet Identifier
topic_filters: Vec<(ByteString, QoS)>
Expand description
the list of Topic Filters and QoS to which the Client wants to subscribe.
Expand description
Subscribe acknowledgment
Show fields
Fields of SubscribeAck
packet_id: NonZeroU16
status: Vec<SubscribeReturnCode>
Expand description
corresponds to a Topic Filter in the SUBSCRIBE Packet being acknowledged.
Expand description
Unsubscribe request
Show fields
Fields of Unsubscribe
packet_id: NonZeroU16
Expand description
Packet Identifier
topic_filters: Vec<ByteString>
Expand description
the list of Topic Filters that the Client wishes to unsubscribe from.
Expand description
Unsubscribe acknowledgment
Show fields
Fields of UnsubscribeAck
packet_id: NonZeroU16
Expand description
Packet Identifier
Expand description
PING request
Expand description
PING response
Expand description
Client is disconnecting
Implementations
impl Packet
[src]
impl Packet
[src]pub fn packet_type(&self) -> u8
[src]
Trait Implementations
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> BorrowMut<T> for T where
T: ?Sized,
[src]
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]pub fn borrow_mut(&mut self) -> &mut T
[src]
pub fn borrow_mut(&mut self) -> &mut T
[src]Mutably borrows from an owned value. Read more
impl<T> Instrument for T
[src]
impl<T> Instrument for T
[src]fn instrument(self, span: Span) -> Instrumented<Self>
[src]
fn instrument(self, span: Span) -> Instrumented<Self>
[src]Instruments this type with the provided Span
, returning an
Instrumented
wrapper. Read more
fn in_current_span(self) -> Instrumented<Self>
[src]
fn in_current_span(self) -> Instrumented<Self>
[src]impl<T> Same<T> for T
impl<T> Same<T> for T
type Output = T
type Output = T
Should always be Self
impl<T> ToOwned for T where
T: Clone,
[src]
impl<T> ToOwned for T where
T: Clone,
[src]type Owned = T
type Owned = T
The resulting type after obtaining ownership.
pub fn to_owned(&self) -> T
[src]
pub fn to_owned(&self) -> T
[src]Creates owned data from borrowed data, usually by cloning. Read more
pub fn clone_into(&self, target: &mut T)
[src]
pub fn clone_into(&self, target: &mut T)
[src]🔬 This is a nightly-only experimental API. (toowned_clone_into
)
recently added
Uses borrowed data to replace owned data, usually by cloning. Read more