Struct JsonlEventSink 

pub struct JsonlEventSink { /* private fields */ }

Writes every event as one JSON line to events.jsonl, teeing metric-bearing events (TrialMetric, MetricReported) into a flat metrics.jsonl for cheap time-series reads.

Writes are buffered and flushed every flush_every events (and on [EventSink::flush]/drop). I/O errors are logged and swallowed — tracking must never take down a training run.

Implementations

impl JsonlEventSink

pub fn create( events_path: &Path, metrics_path: Option<&Path>, flush_every: usize, ) -> Result<Self>

Create fresh log files (truncating any existing ones).

pub fn append( events_path: &Path, metrics_path: Option<&Path>, flush_every: usize, start_seq: u64, ) -> Result<Self>

Open existing logs in append mode, continuing at start_seq.

pub fn next_seq(&self) -> u64

Next sequence number to be assigned (== events recorded so far when starting from zero).

Trait Implementations

impl Drop for JsonlEventSink

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.

impl EventSink for JsonlEventSink

fn record(&self, event: &Event)

Record one event. Called synchronously on the emitting thread.

fn flush(&self)

Flush any buffered state to durable storage.