Skip to main content

read_all_events

Function read_all_events 

Source
pub fn read_all_events(events_path: &Path) -> Result<Vec<Event>>
Expand description

Read every event from events.jsonl. Used by tests and reducer replays.

§Torn-line policy

Built on the shared for_each_event_probe (hence PhysicalLineReader), so it matches find_prior_with_key and recover_last_seq exactly: a torn final line lacking a trailing \n is an in-flight partial write, dropped without parsing even if its bytes happen to be valid JSON. Any newline-terminated line that fails to parse is interior corruption and surfaces as Error::CorruptEventLog — not a transient JSON fault — so a replay rejects a poisoned log loudly instead of silently dropping a line.