Struct MsgMeta 

pub struct MsgMeta {
    pub tx: String,
    pub rx: String,
    pub key: String,
    pub kind: MsgKind,
    pub correlation_id: Uuid,
    pub route: Route,
    pub payload_size: u64,
    pub auth_token: Option<String>,
    pub auth_data: Option<Value>,
    pub attachments: Vec<Attachment>,
}

Message meta data. Message passing protocol is build around this structure.

Fields

tx: String

Addr of message sender

rx: String

Addr of message receiver

key: String

Logic key for message processing

kind: MsgKind

Defines what kind of message it is

correlation_id: Uuid

Correlation id is needed for rpc and for message chains

route: Route

Logical message route, receiver are responsible for moving message on.

payload_size: u64

Size of payload, used for deserialization. Also useful for monitoring.

auth_token: Option<String>

Authorization token.

auth_data: Option<Value>

Authorization data.

attachments: Vec<Attachment>

Attachments to message

Implementations

impl MsgMeta

pub fn content_len(&self) -> u64

Payload plus attachments len.

pub fn attachments_len(&self) -> u64

Attachments len.

pub fn attachments_sizes(&self) -> Vec<u64>

Attachments sizes.

pub fn display(&self) -> String

Short display of message meta data

pub fn key_part(&self, index: usize) -> Result<&str, String>

Get key part, index is zero based, . is used as a separator.

pub fn match_key_part(&self, index: usize, value: &str) -> Result<bool, String>

Compares key part with passed value, index is zero based, . is used as a separator.

pub fn tx_part(&self, index: usize) -> Result<&str, String>

Get tx part, index is zero based, . is used as a separator.

pub fn match_tx_part(&self, index: usize, value: &str) -> Result<bool, String>

Compares tx part with passed value, index is zero based, . is used as a separator.

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

pub fn source_cmp_part(&self, index: usize) -> Result<&str, String>

Get source cmp part, index is zero based, . is used as a separator.

pub fn match_source_cmp_part( &self, index: usize, value: &str, ) -> Result<bool, String>

Compares source cmp part with passed value, index is zero based, . is used as a separator.

pub fn source_cmp_part_before_last(&self) -> Result<&str, String>

Get source cmp part before last one, . is used as a separator.

pub fn source_svc_addr(&self) -> Option<String>

pub fn client_cmp_addr(&self) -> Option<String>

pub fn client_svc_addr(&self) -> Option<String>

Trait Implementations

impl Clone for MsgMeta

fn clone(&self) -> MsgMeta

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MsgMeta

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for MsgMeta

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for MsgMeta

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

where __S: Serializer,

Serialize this value into the given Serde serializer.