← Back

Module mqtt

enum ProtocolVersion

Source: mqtt.joule:19

fn level(&self) -> u8

Source: mqtt.joule:29

fn name(&self) -> &'static [u8]

Source: mqtt.joule:37

enum QoS

Source: mqtt.joule:51

fn from_u8(value: u8) -> Option<Self>

Source: mqtt.joule:61

enum PacketType

Source: mqtt.joule:78

fn from_u8(value: u8) -> Option<Self>

Source: mqtt.joule:97

struct ConnectOptions

Source: mqtt.joule:125

fn default() -> Self

Source: mqtt.joule:157

fn new() -> Self

Source: mqtt.joule:178

fn client_id(mut self, id: &str) -> Self

Source: mqtt.joule:182

fn keep_alive(mut self, seconds: u16) -> Self

Source: mqtt.joule:187

fn clean_session(mut self, clean: bool) -> Self

Source: mqtt.joule:192

fn credentials(mut self, username: &str, password: &[u8]) -> Self

Source: mqtt.joule:197

fn will(mut self, will: LastWill) -> Self

Source: mqtt.joule:203

fn use_tls(mut self, tls: bool) -> Self

Source: mqtt.joule:208

fn v5(mut self) -> Self

Source: mqtt.joule:213

struct LastWill

Source: mqtt.joule:221

fn new(topic: &str, payload: Vec<u8>) -> Self

Source: mqtt.joule:237

fn qos(mut self, qos: QoS) -> Self

Source: mqtt.joule:248

fn retain(mut self, retain: bool) -> Self

Source: mqtt.joule:253

struct Message

Source: mqtt.joule:265

fn new(topic: &str, payload: Vec<u8>) -> Self

Source: mqtt.joule:295

fn qos(mut self, qos: QoS) -> Self

Source: mqtt.joule:313

fn retain(mut self, retain: bool) -> Self

Source: mqtt.joule:318

fn payload_str(&self) -> Option<&str>

Get payload as string

Source: mqtt.joule:324

enum PayloadFormat

Source: mqtt.joule:331

struct TopicFilter

Source: mqtt.joule:342

fn new(filter: &str, qos: QoS) -> Self

Source: mqtt.joule:356

enum RetainHandling

Source: mqtt.joule:369

enum ConnectReturnCode

Source: mqtt.joule:384

fn from_u8(value: u8) -> Option<Self>

Source: mqtt.joule:394

enum ReasonCode

Source: mqtt.joule:409

enum ClientState

Source: mqtt.joule:463

struct MqttClient

MQTT client

Source: mqtt.joule:471

struct MqttConnection

Source: mqtt.joule:482

enum ConnectionStream

Source: mqtt.joule:487

struct PendingAck

Source: mqtt.joule:492

fn new(options: ConnectOptions) -> Self

Create new MQTT client

Source: mqtt.joule:499

fn connect(&self, host: &str, port: u16) -> Result<(), MqttError>

Source: mqtt.joule:516

fn send_connect(&self) -> Result<(), MqttError>

Source: mqtt.joule:561

fn encode_connect_properties(&self) -> Vec<u8>

Source: mqtt.joule:643

fn encode_will_properties(&self, will: &LastWill) -> Vec<u8>

Source: mqtt.joule:669

fn recv_connack(&self) -> Result<bool, MqttError>

Source: mqtt.joule:680

fn publish(&self, message: &Message) -> Result<(), MqttError>

Source: mqtt.joule:718

fn encode_publish_properties(&self, message: &Message) -> Vec<u8>

Source: mqtt.joule:786

fn subscribe(&self, filters: &[TopicFilter]) -> Result<Vec<QoS>, MqttError>

Source: mqtt.joule:822

fn recv_suback(&self, expected_id: u16) -> Result<Vec<QoS>, MqttError>

Source: mqtt.joule:873

fn unsubscribe(&self, topics: &[&str]) -> Result<(), MqttError>

Source: mqtt.joule:912

fn recv(&self) -> Result<Message, MqttError>

Source: mqtt.joule:948

fn parse_publish(&self, packet: &[u8], flags: u8) -> Result<Message, MqttError>

Source: mqtt.joule:975

fn disconnect(&self) -> Result<(), MqttError>

Source: mqtt.joule:1037

fn ping(&self) -> Result<(), MqttError>

Source: mqtt.joule:1058

fn ensure_connected(&self) -> Result<(), MqttError>

Source: mqtt.joule:1070

fn next_packet_id(&self) -> u16

Source: mqtt.joule:1077

fn write_packet(&self, header: &[u8], payload: &[u8]) -> Result<(), MqttError>

Source: mqtt.joule:1087

fn read_packet(&self) -> Result<Vec<u8>, MqttError>

Source: mqtt.joule:1105

fn wait_for_ack(&self, _packet_id: u16) -> Result<(), MqttError>

Source: mqtt.joule:1122

fn handle_packet(&self, _packet: &[u8]) -> Result<(), MqttError>

Source: mqtt.joule:1128

fn send_puback(&self, packet_id: u16) -> Result<(), MqttError>

Source: mqtt.joule:1133

fn send_pubrec(&self, packet_id: u16) -> Result<(), MqttError>

Source: mqtt.joule:1146

fn send_pubrel(&self, packet_id: u16) -> Result<(), MqttError>

Source: mqtt.joule:1159

fn send_pingresp(&self) -> Result<(), MqttError>

Source: mqtt.joule:1172

fn build_fixed_header(packet_type: PacketType, flags: u8, remaining_len: usize) -> Vec<u8>

Source: mqtt.joule:1182

fn encode_variable_int(value: u32) -> Vec<u8>

Source: mqtt.joule:1194

fn decode_variable_int(data: &[u8]) -> Result<(u32, usize), MqttError>

Source: mqtt.joule:1216

fn topic_matches(filter: &str, topic: &str) -> bool

Check if a topic matches a filter pattern

Source: mqtt.joule:1241

enum MqttError

Source: mqtt.joule:1274

fn from(e: std::io::Error) -> Self

Source: mqtt.joule:1289

fn from(e: TcpError) -> Self

Source: mqtt.joule:1295

fn from(e: super::tls::TlsError) -> Self

Source: mqtt.joule:1301

fn test_qos_ordering()

Source: mqtt.joule:1315

fn test_variable_int_encoding()

Source: mqtt.joule:1321

fn test_variable_int_decoding()

Source: mqtt.joule:1329

fn test_topic_matching()

Source: mqtt.joule:1336

fn test_message_creation()

Source: mqtt.joule:1350

fn test_connect_options()

Source: mqtt.joule:1362

fn test_last_will()

Source: mqtt.joule:1376