Struct MessageEnvelope 

pub struct MessageEnvelope {
    pub id: Uuid,
    pub sender: Uuid,
    pub recipient: MessageTarget,
    pub payload: Payload,
    pub timestamp: DateTime<Utc>,
    pub ttl: Option<u32>,
    pub correlation_id: Option<Uuid>,
}

A message envelope that wraps any payload with routing metadata.

This is the universal message format used across all transports. Transports serialize/deserialize envelopes to their wire format.

Fields

id: Uuid

Unique message identifier.

sender: Uuid

The sender’s agent identity UUID.

recipient: MessageTarget

Who this message is addressed to.

payload: Payload

The message payload.

timestamp: DateTime<Utc>

When the message was created.

ttl: Option<u32>

Optional time-to-live (number of hops before the message is dropped).

correlation_id: Option<Uuid>

Optional correlation ID for request-response patterns.

Implementations

impl MessageEnvelope

pub fn direct( sender: Uuid, recipient: Uuid, payload: impl Into<Payload>, ) -> MessageEnvelope

Create a new envelope addressed to a specific agent.

pub fn broadcast(sender: Uuid, payload: impl Into<Payload>) -> MessageEnvelope

Create a new broadcast envelope.

pub fn topic( sender: Uuid, topic: impl Into<String>, payload: impl Into<Payload>, ) -> MessageEnvelope

Create a new topic-addressed envelope.

pub fn with_ttl(self, ttl: u32) -> MessageEnvelope

Set the TTL on this envelope.

pub fn with_correlation(self, correlation_id: Uuid) -> MessageEnvelope

Set a correlation ID for request-response tracking.

pub fn reply( &self, sender: Uuid, payload: impl Into<Payload>, ) -> MessageEnvelope

Create a reply envelope to this message.

Trait Implementations

impl Clone for MessageEnvelope

fn clone(&self) -> MessageEnvelope

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MessageEnvelope

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for MessageEnvelope

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for MessageEnvelope

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

where __S: Serializer,

Serialize this value into the given Serde serializer.