Struct ExecEventRecorder 

pub struct ExecEventRecorder { /* private fields */ }

Helper responsible for recording execution events and relaying them to optional sinks.

Implementations

impl ExecEventRecorder

pub fn new( thread_id: impl Into<String>, event_sink: Option<EventSink>, thread_handle: Option<ThreadRuntimeHandle>, ) -> Self

pub fn record_exec_session_output( &mut self, call_item_id: &str, tool_name: &str, args: &Value, output: &Value, )

Attach a session result to its original verifier’s canonical output.

pub fn record_thread_event(&mut self, event: ThreadEvent)

pub fn record_thread_events<I>(&mut self, events: I)

where I: IntoIterator<Item = ThreadEvent>,

pub fn turn_started(&mut self)

pub fn task_started(&mut self, goal: &str) -> String

Start a task with its original public request.

pub fn turn_completed(&mut self, usage: Usage)

pub fn turn_failed(&mut self, message: &str, usage: Option<Usage>)

pub fn turn_blocked(&mut self, event: TurnBlockedEvent)

pub fn thread_completed( &mut self, session_id: &str, subtype: ThreadCompletionSubtype, outcome_code: &str, result: Option<&str>, stop_reason: Option<&str>, usage: Usage, total_cost_usd: Option<Number>, num_turns: usize, )

pub fn thread_failed( &mut self, session_id: &str, message: &str, num_turns: usize, )

Record the terminal lifecycle events for an execution failure.

pub fn compact_boundary( &mut self, trigger: CompactionTrigger, mode: CompactionMode, original_message_count: usize, compacted_message_count: usize, history_artifact_path: Option<&str>, previous_envelope: Option<&SessionRequestEnvelope>, new_envelope: Option<&SessionRequestEnvelope>, )

pub fn agent_message(&mut self, text: &str)

pub fn agent_message_stream_update(&mut self, text: &str) -> bool

pub fn agent_message_stream_complete(&mut self)

pub fn reasoning(&mut self, text: &str)

pub fn set_reasoning_stage(&mut self, stage: &str)

pub fn reasoning_stream_update(&mut self, text: &str) -> bool

pub fn reasoning_stream_complete(&mut self)

pub fn tool_started( &mut self, tool_name: &str, arguments: Option<&Value>, tool_call_id: Option<&str>, ) -> ActiveToolHandle

pub fn tool_finished( &mut self, handle: &ActiveToolHandle, status: ToolCallStatus, exit_code: Option<i32>, aggregated_output: &str, spool_path: Option<&str>, )

pub fn tool_output_started( &mut self, call_item_id: &str, tool_call_id: Option<&str>, )

pub fn tool_output_updated( &mut self, call_item_id: &str, tool_call_id: Option<&str>, output: &str, )

pub fn tool_output_finished( &mut self, call_item_id: &str, tool_call_id: Option<&str>, status: ToolCallStatus, exit_code: Option<i32>, aggregated_output: &str, spool_path: Option<&str>, )

pub fn tool_rejected( &mut self, tool_name: &str, arguments: Option<&Value>, tool_call_id: Option<&str>, detail: &str, )

pub fn permission_requested(&mut self, tool_name: &str)

pub fn permission_resolved( &mut self, tool_name: &str, decision: PermissionDecision, wait_ms: u64, )

pub fn command_started(&mut self, command: &str) -> ActiveCommandHandle

pub fn command_finished( &mut self, handle: &ActiveCommandHandle, status: CommandExecutionStatus, exit_code: Option<i32>, aggregated_output: &str, )

pub fn warning(&mut self, message: &str)

pub fn harness_event( &mut self, event: HarnessEventKind, message: Option<String>, command: Option<String>, path: Option<String>, exit_code: Option<i32>, attempt: Option<u32>, error_category: Option<String>, )

pub fn record_tool_latency(&mut self, tool_name: &str, duration_ms: u64)

Emit a tool latency harness event with recorded duration.

pub fn record_tool_outcome( &mut self, tool_name: &str, attempts: u32, duration_ms: u64, error_category: Option<&str>, )

Emit the single terminal harness observation for one invocation.

pub fn error_recovered( &mut self, tool_name: &str, attempt: u32, error_category: &str, )

Emit an ErrorRecovered harness event, recording that the agent successfully recovered from a transient error after retries.

pub fn tool_retry_attempted( &mut self, tool_name: &str, attempt: u32, error_category: &str, delay_ms: u64, )

Emit a ToolRetryAttempted harness event, recording that a transient tool failure triggered an automatic retry.

pub fn take_events(&mut self) -> Vec<ThreadEvent>

Drain the collected events while keeping the recorder available for a terminal failure path that may run after the normal result assembly.

pub fn into_events(self) -> Vec<ThreadEvent>

Trait Implementations

impl Default for ExecEventRecorder

fn default() -> Self

Returns the “default value” for a type.