Struct JsonlEventStore 

pub struct JsonlEventStore { /* private fields */ }

JSONL-based event store

Stores events in JSONL files, one file per execution. Directory structure: {base_dir}/{execution_id}.jsonl

Implementations

impl JsonlEventStore

pub async fn new(base_dir: PathBuf) -> Result<Self>

Create a new JSONL event store at the given directory

Trait Implementations

impl Debug for JsonlEventStore

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl EventStore for JsonlEventStore

fn append<'life0, 'async_trait>( &'life0 self, event: ExecutionEvent, ) -> Pin<Box<dyn Future<Output = Result<EventLogEntry>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Append an event to the log

fn get_by_execution<'life0, 'life1, 'async_trait>( &'life0 self, execution_id: &'life1 ExecutionId, ) -> Pin<Box<dyn Future<Output = Result<Vec<EventLogEntry>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Get events for an execution

fn get_after<'life0, 'async_trait>( &'life0 self, after_sequence: u64, limit: usize, ) -> Pin<Box<dyn Future<Output = Result<Vec<EventLogEntry>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get events after a sequence number

fn latest_sequence<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<u64>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get the latest sequence number