Struct Message 

pub struct Message {
    pub id: String,
    pub target: String,
    pub origin: Option<String>,
    pub event: String,
    pub data: Option<JsonValue>,
    pub sendid: Option<String>,
    pub correlation: Option<String>,
}

A Vertep envelope on the wire.

Fields

id: String

The message id, the receiver’s deduplication key.

target: String

The receiver’s IRI.

origin: Option<String>

The sender’s IRI.

event: String

The event name.

data: Option<JsonValue>

The payload, in the runtime’s lossless JSON encoding.

sendid: Option<String>

The send id (_event.sendid).

correlation: Option<String>

A request’s correlation id, or the one a reply answers.

Implementations

impl Message

pub fn from_envelope(env: &Envelope) -> Self

The wire form of env.

pub fn into_envelope(self) -> Envelope

The envelope a receiver delivers: an external event whose origin type names this processor and whose origin is the sender’s IRI.

Trait Implementations

impl Clone for Message

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Message

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Message

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for Message

fn eq(&self, other: &Self) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl Serialize for Message

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for Message