Struct Client

pub struct Client<'id, 'hn, 'psk, 'b, const N: usize> { /* private fields */ }

Available on crate feature w5500-tls only.

W5500 MQTT client over TLS.

The methods are nearly identical to crate::Client, see crate::Client for additional documentation and examples.

Implementations

impl<'id, 'hn, 'psk, 'b, const N: usize> Client<'id, 'hn, 'psk, 'b, N>

pub fn new( sn: Sn, src_port: u16, hostname: Hostname<'hn>, dst: SocketAddrV4, identity: &'psk [u8], psk: &'psk [u8], rx: &'b mut [u8; N], ) -> Self

Create a new MQTT client.

Arguments

• sn - The socket number to use for MQTT.
• src_port - The MQTT source port, this is typically SRC_PORT.
• server - The IP address and port for the MQTT server.

Example

use w5500_mqtt::{
    hl::Hostname,
    ll::{
        net::{Ipv4Addr, SocketAddrV4},
        Sn,
    },
    tls::{Client, DST_PORT},
    SRC_PORT,
};

static mut RXBUF: [u8; 2048] = [0; 2048];

let client: Client<2048> = Client::new(
    Sn::Sn2,
    SRC_PORT,
    Hostname::new_unwrapped("mqtt.local"),
    SocketAddrV4::new(Ipv4Addr::new(192, 168, 5, 6), DST_PORT),
    load_identity_from_memory(),
    &load_key_from_memory(),
    unsafe { &mut RXBUF },
);

pub fn set_client_id(&mut self, client_id: ClientId<'id>)

Set the MQTT client ID.

pub fn process<'w, 'ptr, W5500: Registers, R: RngCore + CryptoRng>( &'ptr mut self, w5500: &'w mut W5500, rng: &mut R, monotonic_secs: u32, ) -> Result<Event<Infallible, TlsReader<'b, 'ptr>>, Error<W5500::Error>>

Process the MQTT client.

pub fn is_connected(&self) -> bool

Returns true if the MQTT client is connected.

pub fn publish<W5500: Registers>( &mut self, w5500: &mut W5500, topic: &str, payload: &[u8], ) -> Result<(), Error<W5500::Error>>

Publish data to the MQTT broker.

pub fn subscribe<W5500: Registers>( &mut self, w5500: &mut W5500, filter: &str, ) -> Result<u16, Error<W5500::Error>>

Subscribe to a topic.

pub fn unsubscribe<W5500: Registers>( &mut self, w5500: &mut W5500, filter: &str, ) -> Result<u16, Error<W5500::Error>>

Unsubscribe from a topic.