Struct FileSpanStore 

pub struct FileSpanStore { /* private fields */ }

A SpanStore that persists each session’s records as a JSON-lines file on disk.

File layout: <base_dir>/<session_id>.jsonl. Records are appended one per line in serialization order; load reads them back in append order and silently skips any malformed trailing line (the only way a partial write can land is when the process is killed mid-write).

Implementations

impl FileSpanStore

pub fn new(base_dir: impl Into<PathBuf>) -> FileSpanStore

Creates a new file-backed span store rooted at base_dir.

The directory is created lazily on the first write.

Trait Implementations

impl Debug for FileSpanStore

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

Formats the value using the given formatter.

impl SpanStore for FileSpanStore

fn append( &self, session_id: &str, record: &SpanRecord, ) -> Pin<Box<dyn Future<Output = Result<(), SpanStoreError>> + Send + '_>>

Append one record to the given session’s history.

fn append_batch<'a>( &'a self, records: &'a [(String, SpanRecord)], ) -> Pin<Box<dyn Future<Output = Result<(), SpanStoreError>> + Send + 'a>>

Append a batch of (session_id, record) pairs durably.

fn load( &self, session_id: &str, ) -> Pin<Box<dyn Future<Output = Result<Vec<SpanRecord>, SpanStoreError>> + Send + '_>>

Load every record stored for session_id, in append order.

fn list_sessions( &self, ) -> Pin<Box<dyn Future<Output = Result<Vec<String>, SpanStoreError>> + Send + '_>>

Lists every session_id that has at least one record stored.

fn delete( &self, session_id: &str, ) -> Pin<Box<dyn Future<Output = Result<(), SpanStoreError>> + Send + '_>>

Delete every record stored for session_id. Missing sessions are not an error.