Struct SourceMsg

pub struct SourceMsg {
    pub id: MsgId,
    pub msg: Msg,
    pub ts: usize,
    pub delivered: usize,
}

Data structure for representing a message as it moves through a topology

Fields

id: MsgId

MsgId as Vec used for keeping track of a source msg

msg: Msg

Msg as Vec

ts: usize

Source msg read timestamp. Message timeouts are computed from this field value

delivered: usize

How many times has this message been delivered? Used for tracking internal retries if topology is configured with TopologyFailurePolicy::Retry(count)

Trait Implementations

impl Clone for SourceMsg

fn clone(&self) -> SourceMsg

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for SourceMsg

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

Formats the value using the given formatter.

impl Default for SourceMsg

fn default() -> SourceMsg

Returns the “default value” for a type.