Struct TapMessage 

pub struct TapMessage {

    pub ident: TapIdent,
    pub subject: String,
    pub size: u64,
    pub outcome: TapOutcome,
    pub seen_at: Instant,
    pub source: TapSource,
    pub station: Option<Arc<str>>,
    pub to_stations: Option<Arc<[Reached]>>,
    pub hops: Vec<Hop>,
    pub reply_to: Option<String>,
    pub held: bool,
    pub payload: Option<Vec<u8>>,
    pub call: Option<CallDetails>,
}

The per-message facts a tap keeps.

Fields

ident: TapIdent

Its id.

subject: String

The subject (channel name).

size: u64

Payload size in bytes.

outcome: TapOutcome

What became of it.

seen_at: Instant

When the server first saw it, on the monotonic clock; the record’s wall time is the tap’s wall base plus the elapsed time to here.

source: TapSource

Who published it.

station: Option<Arc<str>>

The station that published it: the registered worker identity of the publishing connection, shared rather than copied. None for a connection that is not a registered worker, and for the server. An embedded host carries its named publisher identity here.

to_stations: Option<Arc<[Reached]>>

The stations that received it: each registered worker whose subscription’s inbox queued the message, once, in the fan-out’s order, shared by every tap that kept it: empty when the recorded fan-out reached no registered worker. None when its recipients were not recorded, so whom it reached is not known.

hops: Vec<Hop>

Where it went, in order.

reply_to: Option<String>

The id of the message it answers, when it has one.

held: bool

Held by a rule. Always false until rules (R4) exist.

payload: Option<Vec<u8>>

The payload, only on a subscription carrying a PayloadGrant.

call: Option<CallDetails>

Terminal call facts; absent on a channel publish.

Trait Implementations

impl Clone for TapMessage

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TapMessage

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

Formats the value using the given formatter.

impl Eq for TapMessage

impl PartialEq for TapMessage

fn eq(&self, other: &Self) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for TapMessage