Struct WorkerTelemetry 

pub struct WorkerTelemetry {
    pub level: TelemetryLevel,
    pub writer: Option<TelemetryWriter>,
    pub parent_session_id: Option<String>,
    pub parent_runtime_session_id: Option<String>,
    pub agent: Option<String>,
    pub handle: Option<String>,
}

The parent session’s telemetry, handed to the subagents it spawns.

Workers record at the parent’s level and enqueue onto the parent’s session writer instead of starting their own: the writer owns its log files from a single thread, so a writer per worker would race rotation. See Runtime::inherit_telemetry.

Fields

level: TelemetryLevel

writer: Option<TelemetryWriter>

The parent’s session writer. None when the parent records nothing.

parent_session_id: Option<String>

The parent’s persisted conversation id (the ~/.synaps-cli/sessions/<id>.json id), stamped on the worker’s records as parent_session_id. None when the parent is unkeyed.

parent_runtime_session_id: Option<String>

The parent’s runtime trace session id (session-<pid>-<ms>-<seq>), stamped as parent_runtime_session_id.

agent: Option<String>

Set per spawn by Self::for_worker: the agent name.

handle: Option<String>

Set per spawn by Self::for_worker: the subagent handle (sa_N).

Implementations

impl WorkerTelemetry

pub fn for_worker(self, agent: &str, handle: &str) -> Self

This telemetry, labelled for one spawned worker.

pub fn worker_writer(&self) -> Option<TelemetryWriter>

The parent’s writer, re-stamped for this worker: every record the worker enqueues carries its identity and its parent’s ids, and NOT the parent’s own session_id.

Trait Implementations

impl Clone for WorkerTelemetry

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WorkerTelemetry

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

Formats the value using the given formatter.

impl Default for WorkerTelemetry

fn default() -> Self

Returns the “default value” for a type.