Struct DispatchAuditEvent 

pub struct DispatchAuditEvent {
    pub rule_id: RuleId,
    pub trigger_kind: TriggerKind,
    pub outcome: DispatchOutcome,
    pub matched_seq: u64,
    pub matched_scope: String,
    pub context_event_count: usize,
    pub peer: Option<String>,
    pub ts_ms: u64,
}

Structured audit record written into scryer’s tower.dispatch scope.

One Dispatched record is written before the trigger fires (idempotency marker). One Failed record is written if the trigger handler errors; the presence of Dispatched without a following Failed indicates successful invocation.

Queryable from scryer via scryer.events(Service(MeshIdent("tower.local"))).

Fields

rule_id: RuleId

trigger_kind: TriggerKind

outcome: DispatchOutcome

matched_seq: u64

Sequence number of the matched event (for cross-referencing).

matched_scope: String

Scope identifier of the matched event, e.g. "service:yubaba.local".

context_event_count: usize

Number of context events included in the dispatch payload.

peer: Option<String>

Peer the event was federated from, if any.

ts_ms: u64

Unix milliseconds at dispatch time.

Implementations

impl DispatchAuditEvent

pub fn to_scryer_event(&self, seq: u64) -> Event

Convert to a scryer event for writing into the tower.dispatch scope.

Scope is Service(MeshIdent("tower.local")) per arch doc §Dispatch step 3. target is "tower.dispatch" on success or "tower.dispatch.failed" on error. seq is supplied by the caller (scryer assigns per-scope sequence numbers).

Trait Implementations

impl Clone for DispatchAuditEvent

fn clone(&self) -> DispatchAuditEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DispatchAuditEvent

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

Formats the value using the given formatter.