Struct MessageEnvelope 

pub struct MessageEnvelope<T> { /* private fields */ }

Versioned transport-neutral message envelope.

The payload is intentionally omitted from Debug output to prevent accidental secret or PII disclosure. Delivery guarantees remain the responsibility of each native broker adapter.

Implementations

impl<T> MessageEnvelope<T>

pub fn new(name: impl Into<String>, payload: T) -> Result<Self>

Creates an envelope with a generated UUID and current UTC timestamp.

pub fn from_parts( id: impl Into<String>, name: impl Into<String>, schema_version: u32, occurred_at_ms: i64, metadata: EnvelopeMetadata, payload: T, ) -> Result<Self>

Creates an envelope from explicit, validated parts.

pub fn with_metadata(self, metadata: EnvelopeMetadata) -> Self

Replaces the envelope metadata.

pub fn id(&self) -> &str

Returns the stable message identifier.

pub fn name(&self) -> &str

Returns the stable message name.

pub const fn schema_version(&self) -> u32

Returns the application schema version.

pub const fn occurred_at_ms(&self) -> i64

Returns the UTC occurrence timestamp in Unix milliseconds.

pub fn metadata(&self) -> &EnvelopeMetadata

Returns the envelope metadata.

pub fn payload(&self) -> &T

Returns the typed payload.

pub fn into_payload(self) -> T

Consumes the envelope and returns the typed payload.

impl<T> MessageEnvelope<T>

where T: Serialize,

pub fn to_json(&self) -> Result<Vec<u8>>

Serializes the envelope as bounded JSON.

pub fn to_json_with_limit(&self, maximum: usize) -> Result<Vec<u8>>

Serializes the envelope as JSON with an explicit byte limit.

impl<T> MessageEnvelope<T>

where T: DeserializeOwned,

pub fn from_json(encoded: &[u8]) -> Result<Self>

Deserializes a bounded JSON envelope.

pub fn from_json_with_limit(encoded: &[u8], maximum: usize) -> Result<Self>

Deserializes JSON after enforcing an explicit inbound byte limit.

Trait Implementations

impl<T: Clone> Clone for MessageEnvelope<T>

fn clone(&self) -> MessageEnvelope<T>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T> Debug for MessageEnvelope<T>

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

Formats the value using the given formatter.

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

where T: Deserialize<'de>,

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl<T: Eq> Eq for MessageEnvelope<T>

impl<T: PartialEq> PartialEq for MessageEnvelope<T>

fn eq(&self, other: &MessageEnvelope<T>) -> bool

Equality operator ==.

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

Inequality operator !=.

impl<T> Serialize for MessageEnvelope<T>

where T: Serialize,

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl<T: PartialEq> StructuralPartialEq for MessageEnvelope<T>