Struct SledStorage 

pub struct SledStorage { /* private fields */ }

Sled-backed implementation of StorageEngine.

Implementations

impl SledStorage

pub fn open( config: SledConfig, key_provider: Arc<dyn KeyProvider>, ) -> Result<Self>

pub fn open_with_env(config: SledConfig) -> Result<Self>

pub fn append_atoms( &self, world: &WorldKey, atoms: Vec<Atom>, ) -> Result<Vec<AtomId>>

Append a batch of atoms to the same world, returning their ids.

pub fn rebuild_index(&self) -> Result<u64>

Rebuild the atom id index from existing worlds/logs; returns entries written.

Trait Implementations

impl StorageEngine for SledStorage

fn append(&self, atom: Atom) -> Result<()>

fn get_by_ids(&self, ids: &[AtomId]) -> Result<Vec<Atom>>

fn scan(&self, world: &WorldKey, filter: &AtomFilter) -> Result<Vec<Atom>>

fn stats(&self, world: &WorldKey) -> Result<StorageStats>

fn list_ids_in_window( &self, world: &WorldKey, window: &TimeWindow, ) -> Result<Vec<AtomId>>

Return atom ids for a world constrained by time window (ms since epoch).

fn delete_atoms(&self, world: &WorldKey, ids: &[AtomId]) -> Result<usize>

Delete atoms by id; returns count removed.

fn worlds(&self) -> Result<Vec<WorldKey>>

List worlds known to the storage implementation.