Struct TraceStore 

pub struct TraceStore { /* private fields */ }

In-memory ring buffer for execution traces.

Implementations

impl TraceStore

pub fn new(config: TraceStoreConfig) -> Self

Create a new trace store.

pub fn record(&mut self, trace: TraceEntry) -> u64

Record a new trace. Returns the assigned trace ID.

pub fn reserve_id(&mut self) -> u64

§Fase 33.c — Reserve a trace ID without recording the entry yet.

Wire-streaming sites (execute_sse_handler) need a trace ID up front so the first axon.token event can carry it on the wire — adopters bind the live stream to the eventual replay surface via this id. The entry is finalized via record_with_id once the executor closes the FlowExecutionEvent channel.

When the store is disabled the call still returns 0 to match record’s disabled-path semantics.

pub fn record_with_id(&mut self, trace: TraceEntry, id: u64)

§Fase 33.c — Persist a trace entry under a previously reserved id.

Pairs with reserve_id: callers reserve early to plumb the id into wire events, then call here once execution has completed with final stats. The capacity / eviction / timestamp semantics match record verbatim — only the id-allocation timing differs.

pub fn get(&self, id: u64) -> Option<&TraceEntry>

Get a trace by ID.

pub fn recent( &self, limit: usize, filter: Option<&TraceFilter>, ) -> Vec<&TraceEntry>

Query recent traces (newest first), optionally filtered.

pub fn len(&self) -> usize

Number of buffered traces.

pub fn is_empty(&self) -> bool

Whether the buffer is empty.

pub fn total_recorded(&self) -> u64

Total traces recorded (including evicted).

pub fn get_mut(&mut self, id: u64) -> Option<&mut TraceEntry>

Get a mutable trace by ID (for annotations).

pub fn annotate(&mut self, id: u64, annotation: TraceAnnotation) -> bool

Annotate a trace by ID. Returns true if the trace was found.

pub fn bulk_delete(&mut self, ids: &[u64]) -> usize

Bulk delete traces by IDs. Returns number actually deleted.

pub fn bulk_annotate( &mut self, ids: &[u64], annotation: TraceAnnotation, ) -> usize

Bulk annotate traces by IDs. Returns number of traces annotated.

pub fn search(&self, query: &str, limit: usize) -> Vec<&TraceEntry>

Full-text search across buffered traces.

Matches the query (case-insensitive substring) against: flow_name, source_file, backend, client_key, event step_name, event detail, annotation text, and annotation tags.

pub fn evict_expired(&mut self) -> usize

Evict traces older than max_age_secs. Returns number evicted. No-op if max_age_secs is 0.

pub fn set_max_age_secs(&mut self, max_age_secs: u64) -> u64

Update retention policy. Returns previous max_age_secs.

pub fn config(&self) -> &TraceStoreConfig

Get configuration.

pub fn stats(&self) -> TraceStoreStats

Compute aggregate statistics across buffered traces.

pub fn aggregate(&self, window_secs: u64) -> TraceAggregate

Aggregate traces within a time window (seconds from now). Returns percentiles, error rate, and per-flow stats. If window_secs is 0, aggregates all buffered traces.

pub fn set_correlation(&mut self, id: u64, correlation_id: &str) -> bool

Set correlation ID on a trace. Returns true if found.

pub fn by_correlation(&self, correlation_id: &str) -> Vec<&TraceEntry>

Find all traces with a given correlation ID.

pub fn clear(&mut self)

Clear all buffered traces.