Struct MessageEnvelope 

pub struct MessageEnvelope {
    pub payload: Vec<u8>,
    pub causal_context: Option<CausalContext>,
    pub timestamp: u64,
    pub publisher_id: String,
    pub idempotency_key: Option<String>,
}

Deterministic storage envelope for durable channel messages.

Fields

payload: Vec<u8>

Opaque message payload bytes.

causal_context: Option<CausalContext>

Optional causal metadata.

timestamp: u64

Publisher-provided epoch-millisecond timestamp.

publisher_id: String

Stable publisher identity.

idempotency_key: Option<String>

Optional producer idempotency key.

Implementations

impl MessageEnvelope

pub fn serialize(&self) -> Result<Vec<u8>, DurabilityError>

Serializes the envelope into a canonical binary representation.

Errors

Returns DurabilityError::EnvelopeError if a field length cannot be represented in the storage format.

pub fn deserialize(bytes: &[u8]) -> Result<Self, DurabilityError>

Deserializes an envelope previously produced by Self::serialize.

Errors

Returns DurabilityError::EnvelopeError when bytes are malformed, truncated, contain invalid UTF-8, or carry trailing data.

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

Formats the value using the given formatter.

impl Eq for MessageEnvelope

impl PartialEq for MessageEnvelope

fn eq(&self, other: &MessageEnvelope) -> 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 MessageEnvelope