Struct svc_agent::mqtt::IncomingEventProperties

pub struct IncomingEventProperties { /* fields omitted */ }

Properties of an incoming event message.

Methods

impl IncomingEventProperties

pub fn to_connection(&self) -> Connection

pub fn label(&self) -> Option<&str>

pub fn long_term_timing(&self) -> &LongTermTimingProperties

pub fn short_term_timing(&self) -> &IncomingShortTermTimingProperties

pub fn tracking(&self) -> &TrackingProperties

pub fn to_event(
    &self,
    label: &'static str,
    short_term_timing: OutgoingShortTermTimingProperties
) -> OutgoingEventProperties

Builds OutgoingEventProperties based on the IncomingEventProperties.

Use it to dispatch an event as a reaction on another event.

Arguments

• label – outgoing event label.
• short_term_timing – outgoing event's short term timing properties.

Example

let short_term_timing = OutgoingShortTermTimingProperties::until_now(start_timestamp);
let out_props = in_props.to_event("agent.enter", short_term_timing);

Trait Implementations

impl Addressable for IncomingEventProperties

fn as_agent_id(&self) -> &AgentId

Returns the AgentId reference of the addressable object.

impl Authenticable for IncomingEventProperties

fn as_account_id(&self) -> &AccountId

impl Clone for IncomingEventProperties

fn clone(&self) -> IncomingEventProperties

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for IncomingEventProperties

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for IncomingEventProperties

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
    __D: Deserializer<'de>, 

Deserialize this value from the given Serde deserializer.

impl Serialize for IncomingEventProperties

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error> where
    __S: Serializer, 

Serialize this value into the given Serde serializer.