Struct RoutedMessage 

pub struct RoutedMessage {
    pub id: u64,
    pub from_peer: String,
    pub topic: String,
    pub payload: Vec<u8>,
    pub priority: MessagePriority,
    pub enqueued_at: Instant,
    pub ttl: Duration,
}

A message travelling through the router.

Fields

id: u64

Monotonically increasing message identifier assigned by the router.

from_peer: String

Originating peer identifier.

topic: String

Topic this message belongs to.

payload: Vec<u8>

Raw payload bytes.

priority: MessagePriority

Priority of this message.

enqueued_at: Instant

Wall-clock time at which the message was enqueued.

ttl: Duration

How long the message remains valid after enqueued_at.

Implementations

impl RoutedMessage

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

Create a new RoutedMessage with the default TTL of 30 s.

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

Returns true when this message has exceeded its TTL relative to now.

Trait Implementations

impl Clone for RoutedMessage

fn clone(&self) -> RoutedMessage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RoutedMessage

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

Formats the value using the given formatter.