Struct ConnectPacket 

pub struct ConnectPacket {
    pub protocol_version: u8,
    pub clean_start: bool,
    pub keep_alive: u16,
    pub client_id: String,
    pub username: Option<String>,
    pub password: Option<Vec<u8>>,
    pub will: Option<WillMessage>,
    pub properties: Properties,
    pub will_properties: Properties,
}

MQTT CONNECT packet

Fields

protocol_version: u8

Protocol version (4 for v3.1.1, 5 for v5.0)

clean_start: bool

Clean start flag (Clean Session in v3.1.1)

keep_alive: u16

Keep alive interval in seconds

client_id: String

Client identifier

username: Option<String>

Username (optional)

password: Option<Vec<u8>>

Password (optional)

will: Option<WillMessage>

Will message (optional)

properties: Properties

CONNECT properties (v5.0 only)

will_properties: Properties

Will properties (v5.0 only)

Implementations

impl ConnectPacket

pub fn new(options: ConnectOptions) -> Self

Creates a new CONNECT packet from options

pub fn new_v311(options: ConnectOptions) -> Self

Creates a v3.1.1 compatible CONNECT packet

Trait Implementations

impl Clone for ConnectPacket

fn clone(&self) -> ConnectPacket

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ConnectPacket

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

Formats the value using the given formatter.

impl MqttPacket for ConnectPacket

fn packet_type(&self) -> PacketType

Returns the packet type

fn encode_body<B: BufMut>(&self, buf: &mut B) -> Result<()>

Encodes the packet body (without fixed header)

fn decode_body<B: Buf>(buf: &mut B, _fixed_header: &FixedHeader) -> Result<Self>

Decodes the packet body (without fixed header)

fn flags(&self) -> u8

Returns the fixed header flags

fn encode<B: BufMut>(&self, buf: &mut B) -> Result<()>

Encodes the complete packet (with fixed header)