Struct MqttPinger 

pub struct MqttPinger {
    pub server: String,
    pub client_id: Option<String>,
    pub keepalive: u16,
    pub timeout: Duration,
    pub version: MqttVersion,
    /* private fields */
}

MQTT pinger.

Speaks plain TCP for mqtt:// (or no scheme) targets and rustls TLS for mqtts://. Reuses zpinger’s webpki-roots default trust store unless a caller-supplied ClientConfig is injected via with_tls_config — same pattern as HttpPinger / WebSocketPinger.

Fields

server: String

client_id: Option<String>

keepalive: u16

timeout: Duration

version: MqttVersion

Implementations

impl MqttPinger

pub fn new(server: impl Into<String>) -> Self

pub fn with_client_id(self, client_id: impl Into<String>) -> Self

pub fn with_keepalive(self, keepalive: u16) -> Self

pub fn with_timeout(self, timeout: Duration) -> Self

pub fn with_version(self, version: MqttVersion) -> Self

pub fn with_tls_config(self, config: Arc<ClientConfig>) -> Self

Trait Implementations

impl Pinger for MqttPinger

fn ping<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,