Struct Message

pub struct Message<T: PayloadSerialize> {
    pub payload: T,
    pub content_type: Option<String>,
    pub format_indicator: FormatIndicator,
    pub custom_user_data: Vec<(String, String)>,
    pub sender_id: Option<String>,
    pub timestamp: Option<HybridLogicalClock>,
    pub topic_tokens: HashMap<String, String>,
}

Telemetry message struct. Used by the Receiver.

Fields

payload: T

Payload of the telemetry message. Must implement PayloadSerialize.

content_type: Option<String>

Content Type of the telemetry message.

format_indicator: FormatIndicator

Format Indicator of the telemetry message.

custom_user_data: Vec<(String, String)>

Custom user data set as custom MQTT User Properties on the telemetry message.

sender_id: Option<String>

If present, contains the client ID of the sender of the telemetry message.

timestamp: Option<HybridLogicalClock>

Timestamp of the telemetry message.

topic_tokens: HashMap<String, String>

Resolved static and dynamic topic tokens from the incoming message’s topic.

Trait Implementations

impl<T: Debug + PayloadSerialize> Debug for Message<T>

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

Formats the value using the given formatter.