Struct MessageEnvelope 

pub struct MessageEnvelope<T = AnyValue> {
    pub topic: String,
    pub seq: u64,
    pub payload: T,
    pub key: Option<String>,
    pub timestamp_ms: u64,
    pub command_id: Option<String>,
    pub idempotency_key: Option<String>,
}

MessageEnvelope data container.

Fields

topic: String

topic field for topic.

seq: u64

seq field for seq.

payload: T

payload field for payload.

key: Option<String>

key field for key.

timestamp_ms: u64

timestamp_ms field for timestamp ms.

command_id: Option<String>

command_id field for command id.

idempotency_key: Option<String>

idempotency_key field for idempotency key.

Implementations

impl MessageEnvelope<AnyValue>

pub fn payload_as<T: 'static>(&self) -> Option<Rc<T>>

Updates or reads payload_as.

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> Debug for MessageEnvelope<T>

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

Formats the value using the given formatter.

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

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