Struct EventReader 

pub struct EventReader { /* private fields */ }

Reads new events from .ralph/events.jsonl since last read.

Implementations

impl EventReader

pub fn new(path: impl Into<PathBuf>) -> Self

Creates a new event reader for the given path.

pub fn read_new_events(&mut self) -> Result<ParseResult>

Reads new events since the last read.

Returns a ParseResult containing both successfully parsed events and information about malformed lines. This enables backpressure validation - the caller can emit event.malformed events and track consecutive failures.

Errors

Returns an error if the file cannot be opened or read.

pub fn peek_new_events(&self) -> Result<ParseResult>

Reads new events without advancing the internal file position.

This is used by callers that need to inspect unread events before deciding whether to process them.

pub fn path(&self) -> &Path

Returns the path to the events file.

pub fn position(&self) -> u64

Returns the current file position.

pub fn set_position(&mut self, position: u64)

Sets the file position to a specific byte offset.

Use this to skip past entries written by the EventLogger so they are not re-read by process_events_from_jsonl.

pub fn reset(&mut self)

Resets the position to the start of the file.