Struct KvStorage 

pub struct KvStorage<B, T, C = JsonCodec>
where
    B: StorageBackend + ?Sized,
    T: Send + Sync + 'static,
    C: Codec<T>,
{ /* private fields */ }

Key-value tier — buffers per-key pending writes; flush() encodes each value via codec and writes it to the backend. Mirrors TS kvStorage.

Trait Implementations

impl<B, T, C> BaseStorageTier for KvStorage<B, T, C>

where B: StorageBackend + ?Sized, T: Send + Sync + 'static, C: Codec<T>,

fn name(&self) -> &str

Diagnostic tier name (e.g. "snapshot:my-graph"). Surfaces in error messages and Display impls.

fn debounce_ms(&self) -> Option<u32>

Debounce window in milliseconds. None (default) = sync-through. Graph-layer attach reads this and schedules timed flush() via its own reactive timer (M4.E); the tier itself does NOT drive a timer.

fn compact_every(&self) -> Option<u32>

Force a flush every Nth accepted write regardless of debounce. None = no cap; Some(N) triggers flush() on the Nth save (or append_entries for log tiers).

fn flush(&self) -> Result<(), StorageError>

Commit pending writes. Graph calls at wave-close / debounce-fire.

fn rollback(&self) -> Result<(), StorageError>

Discard pending writes. Graph calls on wave-throw.

fn list_by_prefix_bytes<'a>( &'a self, prefix: &str, ) -> Box<dyn Iterator<Item = Result<(String, Vec<u8>), StorageError>> + 'a>

Lazily enumerate raw (key, bytes) pairs under a literal byte-prefix (DS-14-storage Q5 lock).

fn compact(&self) -> Result<(), StorageError>

Force a mode:"full" baseline immediately (Q8 lock). Bypasses compact_every cadence; useful at deploy boundaries, end-of-process drains, or test fixtures. Default impl is a flush() so tiers that don’t write baselines can still implement the method trivially.

impl<B, T, C> KvStorageTier<T> for KvStorage<B, T, C>

where B: StorageBackend + ?Sized, T: Send + Sync + 'static, C: Codec<T>,

fn save(&self, key: &str, value: T) -> Result<(), StorageError>

Buffer a key→value mapping pending flush. Repeated save(k, _) before flush overwrites the buffered value for that key. Honors compact_every cadence.

fn load(&self, key: &str) -> Result<Option<T>, StorageError>

Read the value at key. Returns Ok(None) on miss.

fn delete(&self, key: &str) -> Result<(), StorageError>

Delete the value at key. Flushes through to the backend immediately (matches TS delete semantics — no debounce).

fn list(&self, prefix: &str) -> Result<Vec<String>, StorageError>

Enumerate keys under prefix (lex-ASC). Delegates to StorageBackend::list via the tier’s backend.