Struct TranscriptWriter 

pub struct TranscriptWriter { /* private fields */ }

Appends TranscriptEntry lines to a JSONL transcript file.

The file handle is kept open for the writer’s lifetime to avoid race conditions from repeated open/close cycles. The handle is wrapped in Arc<Mutex<File>> so the writer can be cheaply cloned and passed to tokio::task::spawn_blocking for non-blocking appends.

Examples

use std::path::Path;
use zeph_subagent::transcript::TranscriptWriter;

let writer = TranscriptWriter::new(Path::new("/tmp/session.jsonl")).unwrap();
// writer.append(seq, &message) to persist each message.

Implementations

impl TranscriptWriter

pub fn new(path: &Path) -> Result<Self>

Create (or open) a JSONL transcript file in append mode.

Creates parent directories if they do not already exist.

Errors

Returns io::Error if the directory cannot be created or the file cannot be opened.

pub async fn append(&self, seq: u32, message: &Message) -> Result<()>

Append a single message as a JSON line and flush immediately.

Serialization is done on the caller’s thread; the blocking write and flush are offloaded to tokio::task::spawn_blocking so the Tokio executor is not stalled.

Errors

Returns io::Error on serialization, write failure, lock poison, or thread-pool panic.

pub fn write_meta( dir: &Path, agent_id: &str, meta: &TranscriptMeta, ) -> Result<()>

Write the meta sidecar file for an agent.

Errors

Returns io::Error on serialization or write failure.

pub async fn write_meta_async( dir: &Path, agent_id: &str, meta: &TranscriptMeta, ) -> Result<()>

Async variant of write_meta that offloads the blocking FS write to a spawn_blocking thread so the Tokio executor is not stalled.

Errors

Returns io::Error on serialization, write failure, or thread-pool panic.

Trait Implementations

impl Clone for TranscriptWriter

fn clone(&self) -> TranscriptWriter

Returns a duplicate of the value.

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

Performs copy-assignment from source.