Struct JsonlEventLog 

pub struct JsonlEventLog { /* private fields */ }

Crash-durable JSONL log containing complete canonical Event envelopes.

An append is acknowledged only after newline-delimited bytes are flushed and sync_data succeeds. A torn final record is an uncommitted tail and is truncated on open; any malformed complete line is corruption. The in-memory index is disposable and rebuilt solely from the canonical log.

Implementations

impl JsonlEventLog

pub async fn open( path: impl AsRef<Path>, ) -> Result<JsonlEventLog, EventLogError>

Open or create a canonical event JSONL file and rebuild its index.

pub fn path(&self) -> &Path

Backing canonical event-log path.

Trait Implementations

impl EventLog for JsonlEventLog

fn append<'life0, 'async_trait>( &'life0 self, request: EventRequest, ) -> Pin<Box<dyn Future<Output = Result<Event, EventLogError>> + Send + 'async_trait>>

where 'life0: 'async_trait, JsonlEventLog: 'async_trait,

Commit a durable request, assigning its event id and persisted sequence.

fn durability(&self) -> EventDurability

Persistence guarantee used for acknowledged appends.

impl EventReader for JsonlEventLog

fn read_page<'life0, 'async_trait>( &'life0 self, request: EventReadRequest, ) -> Pin<Box<dyn Future<Output = Result<EventPage, EventLogError>> + Send + 'async_trait>>

where 'life0: 'async_trait, JsonlEventLog: 'async_trait,

Read one page. The first page fixes a snapshot high-watermark; continuations cannot observe concurrent appends and therefore neither skip nor duplicate.