Struct JsonlStore 

pub struct JsonlStore { /* private fields */ }

Append-only JSON-lines store. All events go to a single events.jsonl; replay filters by stream key. Simple and debuggable for the first stab; rotation and per-agent sharding are deferred.

Implementations

impl JsonlStore

pub fn open(dir: &Path) -> Result<Self>

Open (creating parent dirs) an append-only store at dir/events.jsonl.

pub fn path(&self) -> &Path

The backing file path.

Trait Implementations

impl Store for JsonlStore

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

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

Append one event to durable storage.

fn replay<'life0, 'life1, 'async_trait>( &'life0 self, stream_key: &'life1 str, from_seq: u64, ) -> Pin<Box<dyn Future<Output = Result<Vec<FleetEvent>>> + Send + 'async_trait>>

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

Replay events for one stream with seq >= from_seq, in seq order.

fn high_water<'life0, 'life1, 'async_trait>( &'life0 self, stream_key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<u64>> + Send + 'async_trait>>

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

The highest seq ever persisted for stream_key (0 if none). Used to resume that stream’s sequence counter across daemon restarts.

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

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

Whether the backend can currently accept writes. A cheap, non-destructive probe used by the readiness endpoint.

fn prune<'life0, 'life1, 'async_trait>( &'life0 self, before_ts: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<u64>> + Send + 'async_trait>>

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

Delete events with ts < before_ts (RFC-3339, lexically ordered). Returns the number removed. Backs age-based retention (#4).

fn usage<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, since: &'life1 str, until: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<UsageRow>>> + Send + 'async_trait>>

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

Aggregate cost, turns, and terminal outcomes per (workspace, UTC day) over [since, until) (RFC-3339, lexically ordered like Store::prune).