Struct DistributedMessage 

pub struct DistributedMessage {
    pub id: u64,
    pub priority: MessagePriority,
    pub payload: Vec<u8>,
    pub enqueued_at: Instant,
    pub ttl: Option<Duration>,
    pub source: String,
    pub destination: String,
}

An envelope wrapping a message payload for the distributed queue.

Fields

id: u64

Unique message identifier.

priority: MessagePriority

Priority of this message.

payload: Vec<u8>

Opaque byte payload.

enqueued_at: Instant

When the message was enqueued.

ttl: Option<Duration>

Optional TTL: message is expired after this duration.

source: String

Source node identifier.

destination: String

Destination node identifier.

Implementations

impl DistributedMessage

pub fn new( id: u64, priority: MessagePriority, payload: Vec<u8>, source: impl Into<String>, destination: impl Into<String>, ) -> Self

Create a new message.

pub fn with_ttl(self, ttl: Duration) -> Self

Attach a time-to-live to the message.

pub fn is_expired(&self, now: Instant) -> bool

Return true if the message’s TTL has elapsed relative to now.

Messages without a TTL never expire.

pub fn payload_len(&self) -> usize

Payload length in bytes.

Trait Implementations

impl Clone for DistributedMessage

fn clone(&self) -> DistributedMessage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DistributedMessage

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

Formats the value using the given formatter.