Struct svc_agent::mqtt::IncomingRequestProperties

pub struct IncomingRequestProperties { /* fields omitted */ }

Methods

impl IncomingRequestProperties

pub fn method(&self) -> &str

pub fn correlation_data(&self) -> &str

pub fn response_topic(&self) -> &str

pub fn broker(&self) -> &BrokerProperties

pub fn to_connection(&self) -> Connection

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

pub fn to_request(
    &self,
    method: &str,
    response_topic: &str,
    correlation_data: &str,
    short_term_timing: ShortTermTimingProperties
) -> OutgoingRequestProperties

pub fn to_response(
    &self,
    status: ResponseStatus,
    short_term_timing: ShortTermTimingProperties
) -> OutgoingResponseProperties

Trait Implementations

impl Addressable for IncomingRequestProperties

fn as_agent_id(&self) -> &AgentId

impl Clone for IncomingRequestProperties

fn clone(&self) -> IncomingRequestProperties

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for IncomingRequestProperties

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

Formats the value using the given formatter.

impl Authenticable for IncomingRequestProperties

fn as_account_id(&self) -> &AccountId

impl Serialize for IncomingRequestProperties

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

Serialize this value into the given Serde serializer.

impl<'de> Deserialize<'de> for IncomingRequestProperties

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

Deserialize this value from the given Serde deserializer.