Struct RunSink 

pub struct RunSink<'a, 'l> {
    pub log: &'a mut LogTarget<'l>,
    pub transcript: &'a mut (dyn Write + Send),
}

Where a run’s event stream lands: every event’s raw JSON goes to the transcript (one line each, scrubbed); selected events are recorded to the LogTarget as worker.message deltas (scrubbed + truncated).

Fields

log: &'a mut LogTarget<'l>

transcript: &'a mut (dyn Write + Send)

Implementations

impl RunSink<'_, '_>

pub fn handle(&mut self, run_id: &str, event: &AgentEvent) -> Result<bool>

Process one event. Returns true when the event was a denied tool result (a guardrail hit, §4.7).

Log mapping: Text → tag "text", ToolUse → "tool-use" (<tool>: <summary>), ToolResult → "denied" or "tool-result"; everything else is transcript-only.