Struct SessionRecorder 

pub struct SessionRecorder<W> { /* private fields */ }

Records session events to a JSONL output.

The recorder is thread-safe and can be used as an EventBus observer. It writes each event as a JSON line immediately for crash resilience.

Example

use ralph_core::SessionRecorder;
use ralph_proto::Event;

let mut output = Vec::new();
let recorder = SessionRecorder::new(&mut output);

// Record a bus event
let event = Event::new("task.start", "Begin implementation");
recorder.record_bus_event(&event);

// Flush and check output
drop(recorder);
let output_str = String::from_utf8_lossy(&output);
assert!(output_str.contains("bus.publish"));

Implementations

impl<W: Write> SessionRecorder<W>

pub fn new(writer: W) -> Self

Creates a new session recorder writing to the given output.

pub fn record_bus_event(&self, event: &Event)

Records an EventBus event.

pub fn record_ux_event(&self, ux_event: &UxEvent)

Records a UX event.

pub fn record_ux_events(&self, events: &[UxEvent])

Records multiple UX events.

pub fn record_meta(&self, record: Record)

Records a metadata event.

pub fn ux_write_count(&self) -> u32

Returns the number of UX write events recorded.

pub fn elapsed(&self) -> Duration

Returns the elapsed time since recording started.

pub fn flush(&self) -> Result<()>

Flushes the underlying writer.

impl<W: Write + Send + 'static> SessionRecorder<W>

pub fn make_observer(recorder: Arc<Self>) -> impl Fn(&Event) + Send + 'static

Creates an observer closure suitable for EventBus::set_observer.

The returned closure holds a reference to this recorder and calls record_bus_event for each event received.

Example

let recorder = Arc::new(SessionRecorder::new(file));
let observer = SessionRecorder::make_observer(Arc::clone(&recorder));
event_bus.set_observer(observer);