Struct TriggerRuntime 

pub struct TriggerRuntime { /* private fields */ }

In-memory dedup + cycle registry shared across all NotificationHook sources for a single agent / daemon. Cloning is cheap; the actual state lives behind an Arc<Mutex>.

Implementations

impl TriggerRuntime

pub fn new() -> Self

Construct a runtime with TriggerRuntimeConfig::default.

pub fn with_config(config: TriggerRuntimeConfig) -> Self

Construct a runtime with a custom config. dedup_window is clamped to TriggerRuntimeConfig::MAX_DEDUP_WINDOW.

pub fn snapshot(&self) -> TriggerRuntimeSnapshot

Point-in-time view of the dedup / cycle bookkeeping plus lifetime counters. Intended for status banners; cheap (one mutex lock + struct copy). Lifetime counters never decrement so consumers can build delta UIs without missing intermediate events.

pub fn config(&self) -> TriggerRuntimeConfig

Convenience getter for the active configuration. Useful in tests and status output.

pub fn evaluate(&self, trigger: &Trigger) -> EvaluationOutcome

Decide whether a fresh trigger should be admitted, deduped, or cycle-suppressed. Pure (modulo wall-clock pruning); does NOT advance the trigger state machine — that’s the harness’s job after it sees the outcome.

Side effects (when the outcome is EvaluationOutcome::Accept):

• inserts the idempotency_key → first-arrival entry into the dedup map
• bumps the trace_id hop counter

On EvaluationOutcome::Deduped or EvaluationOutcome::CycleSuppressed the internal maps are not mutated for that trigger (the prior entry stands; the cycle counter does not advance on a suppressed trigger).

pub fn record_follow_up_hop(&self, trace_id: &str, now: DateTime<Utc>)

Record an additional hop on trace_id without going through dedup. Called by the harness immediately before spawning a follow-up trigger that inherits the parent’s trace (e.g. an AgentDelegate trigger emitted by a tool call).

now is wall-clock time at the moment the follow-up is queued; used both to bump the entry’s last_seen_at and to drive lazy pruning of stale trace entries.

Trait Implementations

impl Clone for TriggerRuntime

fn clone(&self) -> TriggerRuntime

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TriggerRuntime

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

Formats the value using the given formatter.

impl Default for TriggerRuntime

fn default() -> Self

Returns the “default value” for a type.