Enum AuditEvent 

pub enum AuditEvent {
    QueryStarted {
        goal: String,
        session_id: String,
        timestamp_ms: u64,
    },
    PeerQueried {
        peer_id: String,
        goal: String,
        timestamp_ms: u64,
    },
    RuleFired {
        rule_id: String,
        bindings: HashMap<String, String>,
        timestamp_ms: u64,
    },
    ResultReceived {
        peer_id: String,
        binding_count: usize,
        is_final: bool,
        timestamp_ms: u64,
    },
    QueryCompleted {
        session_id: String,
        total_results: usize,
        duration_ms: u64,
        timestamp_ms: u64,
    },
    QueryFailed {
        session_id: String,
        reason: String,
        timestamp_ms: u64,
    },
}

A single observable event in the lifetime of a distributed inference query.

Variants

QueryStarted

The inference session was initiated for the given goal.

Fields

goal: String

The goal string being resolved (e.g. "parent(X, alice)").

session_id: String

Session identifier that scopes this query.

timestamp_ms: u64

Wall-clock time in milliseconds since UNIX epoch.

PeerQueried

A remote peer was contacted to help resolve the goal.

Fields

peer_id: String

Identifier of the remote peer (e.g. multiaddr or libp2p PeerId).

goal: String

The specific sub-goal forwarded to that peer.

timestamp_ms: u64

Wall-clock time in milliseconds since UNIX epoch.

RuleFired

A local or remote rule matched and produced bindings.

Fields

rule_id: String

Stable rule identifier (e.g. "rule:parent/2#3").

bindings: HashMap<String, String>

Variable bindings produced by this rule application.

timestamp_ms: u64

Wall-clock time in milliseconds since UNIX epoch.

ResultReceived

A batch of results was received from a remote peer.

Fields

peer_id: String

Peer that returned this batch.

binding_count: usize

Number of variable bindings in this batch.

is_final: bool

Whether this is the peer’s final response for the sub-goal.

timestamp_ms: u64

Wall-clock time in milliseconds since UNIX epoch.

QueryCompleted

The inference session completed successfully.

Fields

session_id: String

Session identifier.

total_results: usize

Total number of result bindings produced across all peers.

duration_ms: u64

Elapsed time from QueryStarted to QueryCompleted in milliseconds.

timestamp_ms: u64

Wall-clock time in milliseconds since UNIX epoch.

QueryFailed

The inference session failed.

Fields

session_id: String

Session identifier.

reason: String

Human-readable failure reason.

timestamp_ms: u64

Wall-clock time in milliseconds since UNIX epoch.

Implementations

impl AuditEvent

pub fn event_type(&self) -> &str

Returns a stable, lowercase string tag for this event variant.

Useful for serialization, metrics labeling, and log filtering.

pub fn timestamp_ms(&self) -> u64

Returns the wall-clock timestamp (ms since UNIX epoch) carried by this event.

Trait Implementations

impl Clone for AuditEvent

fn clone(&self) -> AuditEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AuditEvent

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

Formats the value using the given formatter.