Struct InfiniteDbStore 

pub struct InfiniteDbStore { /* private fields */ }

A durable store for frp graph entities backed by InfiniteDb.

Uses a write-through cache: all reads are served from in-memory HashMaps (required because the store traits return borrowed &Self::* references). Writes go to both the in-memory cache and the database WAL.

Call flush before process exit to seal buffered WAL records into on-disk blocks.

Implementations

impl InfiniteDbStore

pub fn open(dir: impl AsRef<Path>) -> Result<Self, StoreError>

Open (or create) the database at dir, register all frp spaces, and warm the in-memory caches by replaying every live record.

pub fn flush(&mut self) -> Result<(), StoreError>

Seal all buffered WAL records into on-disk blocks.

Call this before process exit to ensure durability.

Trait Implementations

impl AtomStore for InfiniteDbStore

type Atom = Atom

The atom value type stored and retrieved by this implementation.

fn get_atom(&self, id: AtomId) -> Result<&Atom, StoreError>

Retrieve an atom by its ID.

fn put_atom(&mut self, atom: Atom) -> Result<(), StoreError>

Insert or replace an atom. The atom’s ID is used as the key.

fn delete_atom(&mut self, id: AtomId) -> Result<(), StoreError>

Delete an atom by ID. Returns StoreError::NotFound if absent.

fn query_atoms(&self, query: &Query) -> Result<QueryResult<&Atom>, StoreError>

Return a paged, optionally-filtered collection of atoms.

impl BlockStore for InfiniteDbStore

type Block = Block

The block value type stored and retrieved by this implementation.

fn get_block(&self, id: BlockId) -> Result<&Block, StoreError>

Retrieve a block by its ID.

fn put_block(&mut self, block: Block) -> Result<(), StoreError>

Insert or replace a block.

fn delete_block(&mut self, id: BlockId) -> Result<(), StoreError>

Delete a block by ID. Returns StoreError::NotFound if absent.

fn query_blocks(&self, query: &Query) -> Result<QueryResult<&Block>, StoreError>

Return a paged, optionally-filtered collection of blocks.

impl EdgeStore for InfiniteDbStore

type Edge = HyperEdge

The edge value type stored and retrieved by this implementation.

fn get_edge(&self, id: EdgeId) -> Result<&HyperEdge, StoreError>

Retrieve an edge by its ID.

fn put_edge(&mut self, edge: HyperEdge) -> Result<(), StoreError>

Insert or replace an edge.

fn delete_edge(&mut self, id: EdgeId) -> Result<(), StoreError>

Delete an edge by ID. Returns StoreError::NotFound if absent.

fn query_edges( &self, query: &Query, ) -> Result<QueryResult<&HyperEdge>, StoreError>

Return a paged, optionally-filtered collection of edges.