Struct TracingCollector 

pub struct TracingCollector { /* private fields */ }

Implementations

impl TracingCollector

pub fn new( output_dir: &Path, service_name: impl Into<String>, redact: bool, trace_tx: Option<UnboundedSender<TraceEvent>>, ) -> Result<Self>

Create a new collector.

Errors

Returns an error if output_dir cannot be created.

pub fn begin_iteration(&mut self, index: usize, user_msg_preview: &str)

Open an iteration span. Call at the start of process_user_message.

pub fn end_iteration(&mut self, index: usize, status: SpanStatus)

Close an iteration span.

pub fn begin_llm_request(&self, iteration_span_id: [u8; 8]) -> SpanGuard

Open an LLM request span. Returns an owned SpanGuard safe to hold across .await.

pub fn end_llm_request(&mut self, guard: SpanGuard, attrs: &LlmAttributes)

Close an LLM request span.

pub fn begin_tool_call( &self, tool_name: &str, iteration_span_id: [u8; 8], ) -> SpanGuard

Open a tool call span, recording the start time as now.

pub fn begin_tool_call_at( &self, tool_name: &str, iteration_span_id: [u8; 8], started_at: &Instant, ) -> SpanGuard

Open a tool call span with a pre-recorded start time.

Use this variant when the tool has already executed (post-hoc assembly pattern) and started_at was captured before the call. The Unix start timestamp is back-computed from started_at.elapsed() so the span is correctly positioned on the timeline.

pub fn end_tool_call( &mut self, guard: SpanGuard, tool_name: &str, attrs: ToolAttributes, )

Close a tool call span.

pub fn begin_memory_search(&self, parent_span_id: [u8; 8]) -> SpanGuard

Open a memory search span.

pub fn end_memory_search( &mut self, guard: SpanGuard, attrs: &MemorySearchAttributes, )

Close a memory search span.

pub fn trace_json_path(&self) -> PathBuf

Return the path to the trace.json file that will be written on finish().

pub fn current_iteration_span_id(&self, index: usize) -> Option<[u8; 8]>

Return the span ID of the currently active iteration, if any.

pub fn session_span_id(&self) -> [u8; 8]

Return the session root span ID (fallback parent when no iteration is active).

pub fn trace_id(&self) -> [u8; 16]

Return the trace ID for this session.

pub fn finish(&mut self)

Finalize the session span and write trace.json.

Safe to call multiple times — subsequent calls after the first are no-ops. Also sends spans over the OTel channel when the otel feature is enabled (C-05).

Trait Implementations

impl Drop for TracingCollector

fn drop(&mut self)

Executes the destructor for this type.