Struct Envelope 

pub struct Envelope {
    pub message_id: MessageId,
    pub payload: Vec<u8>,
    pub causal_context: Option<CausalContext>,
    pub schema_id: SchemaId,
    pub publisher_id: PublisherId,
    pub timestamp: DateTime<Utc>,
}

Message envelope used as the delivery unit inside the core bus.

Fields

message_id: MessageId

UUID-based unique identifier assigned when the message is published.

payload: Vec<u8>

Validated payload bytes, normalized by the schema when defaults are applied.

causal_context: Option<CausalContext>

Optional parent reference for causal-chain metadata.

schema_id: SchemaId

Schema version that validated this payload.

publisher_id: PublisherId

Publisher identity attached at publish time.

timestamp: DateTime<Utc>

UTC timestamp captured when the message was published.

Implementations

impl Envelope

pub fn new( payload: Vec<u8>, causal_context: Option<CausalContext>, schema_id: SchemaId, publisher_id: PublisherId, ) -> Self

Creates an envelope with the current UTC publish timestamp.

pub fn with_timestamp( payload: Vec<u8>, causal_context: Option<CausalContext>, schema_id: SchemaId, publisher_id: PublisherId, timestamp: DateTime<Utc>, ) -> Self

Creates an envelope with an explicit timestamp.

pub fn with_message_id( message_id: MessageId, payload: Vec<u8>, causal_context: Option<CausalContext>, schema_id: SchemaId, publisher_id: PublisherId, ) -> Self

Creates an envelope with an explicit message identifier and current UTC timestamp.

pub const fn with_message_id_and_timestamp( message_id: MessageId, payload: Vec<u8>, causal_context: Option<CausalContext>, schema_id: SchemaId, publisher_id: PublisherId, timestamp: DateTime<Utc>, ) -> Self

Creates an envelope with explicit message identifier and timestamp.

Trait Implementations

impl Clone for Envelope

fn clone(&self) -> Envelope

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Envelope

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

Formats the value using the given formatter.

impl Eq for Envelope

impl PartialEq for Envelope

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for Envelope