Struct RoutingMessage 

pub struct RoutingMessage {
    pub id: u64,
    pub topic: MessageTopic,
    pub payload_size: usize,
    pub sender: String,
    pub timestamp: u64,
    pub ttl: u8,
    pub priority: u8,
}

A message travelling through SubscriptionRouter.

The id field is computed as the FNV-1a hash of sender + topic.0 + timestamp.to_string() at construction time.

Fields

id: u64

FNV-1a hash of (sender + topic + timestamp).

topic: MessageTopic

Topic this message belongs to.

payload_size: usize

Number of bytes in the logical payload.

sender: String

Originating peer identifier.

timestamp: u64

Wall-clock millisecond timestamp at which the message was created.

ttl: u8

Remaining hops; the router drops messages where ttl == 0 before delivering them.

priority: u8

Priority: 0 = lowest, 255 = highest.

Implementations

impl RoutingMessage

pub fn new( topic: MessageTopic, payload_size: usize, sender: impl Into<String>, timestamp: u64, ttl: u8, priority: u8, ) -> Self

Create a new RoutingMessage, computing its id automatically.

Trait Implementations

impl Clone for RoutingMessage

fn clone(&self) -> RoutingMessage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RoutingMessage

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

Formats the value using the given formatter.