Struct FileStore 

pub struct FileStore { /* private fields */ }

JSON file-based persistent Store

Implementations

impl FileStore

pub fn new(path: impl AsRef<Path>) -> Result<FileStore, ReactError>

Open or create the Store file, auto-create parent directories

pub async fn put_batch( &self, entries: impl IntoIterator<Item = (Vec<&str>, &str, Value)>, ) -> Result<(), ReactError>

Batch write: write multiple records to memory then flush to disk once, reducing IO overhead.

pub async fn flush_public(&self) -> Result<(), ReactError>

Flush in-memory data to disk.

Trait Implementations

impl Store for FileStore

fn put<'a>( &'a self, namespace: &'a [&'a str], key: &'a str, value: Value, ) -> Pin<Box<dyn Future<Output = Result<(), ReactError>> + Send + 'a>>

Write or update a record (upsert)

fn get<'a>( &'a self, namespace: &'a [&'a str], key: &'a str, ) -> Pin<Box<dyn Future<Output = Result<Option<StoreItem>, ReactError>> + Send + 'a>>

Exact fetch by key

fn search<'a>( &'a self, namespace: &'a [&'a str], query: &'a str, limit: usize, ) -> Pin<Box<dyn Future<Output = Result<Vec<StoreItem>, ReactError>> + Send + 'a>>

Keyword search, returns at most limit items (sorted by relevance)

fn delete<'a>( &'a self, namespace: &'a [&'a str], key: &'a str, ) -> Pin<Box<dyn Future<Output = Result<bool, ReactError>> + Send + 'a>>

Delete the specified key, returns whether it existed and was deleted

fn list_namespaces<'a>( &'a self, prefix: Option<&'a [&'a str]>, ) -> Pin<Box<dyn Future<Output = Result<Vec<Vec<String>>, ReactError>> + Send + 'a>>

List all namespaces matching the given prefix

fn list<'a>( &'a self, namespace: &'a [&'a str], ) -> Pin<Box<dyn Future<Output = Result<Vec<StoreItem>, ReactError>> + Send + 'a>>

List all entries in the namespace (no keyword filter, no pagination limit).

fn search_with<'a>( &'a self, namespace: &'a [&'a str], query: SearchQuery<'a>, ) -> Pin<Box<dyn Future<Output = Result<Vec<StoreItem>, ReactError>> + Send + 'a>>

Unified search entry point.