Struct ExpiringMessage 

pub struct ExpiringMessage {
    pub topic: String,
    pub payload: Vec<u8>,
    pub qos: QoS,
    pub retain: bool,
    pub packet_id: Option<u16>,
    pub expiry_time: Option<Instant>,
    pub expiry_interval: Option<u32>,
}

Fields

topic: String

payload: Vec<u8>

qos: QoS

retain: bool

packet_id: Option<u16>

expiry_time: Option<Instant>

expiry_interval: Option<u32>

Implementations

impl ExpiringMessage

pub fn new( topic: String, payload: Vec<u8>, qos: QoS, retain: bool, packet_id: Option<u16>, expiry_interval: Option<u32>, limits: &LimitsManager, ) -> Self

pub fn is_expired(&self) -> bool

pub fn remaining_expiry_interval(&self) -> Option<u32>

Trait Implementations

impl Clone for ExpiringMessage

fn clone(&self) -> ExpiringMessage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ExpiringMessage

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

Formats the value using the given formatter.