Struct ShadowKVStore

pub struct ShadowKVStore<S: KVStore> { /* private fields */ }

This store will buffer all the atomic writes made by atomic_write, until the invocation of commit. This creates a tranasprent layer to defer/aggregate the writes into a coarser atomic commit.

Implementations

impl<S: KVStore> ShadowKVStore<S>

pub fn new(inner: S) -> Self

impl<S: KVStore> ShadowKVStore<S>

pub fn changes(&self) -> RwLockWriteGuard<'_, HashMap<Key, Option<Value>>>

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

Trait Implementations

impl<S: KVStore> KVStore for ShadowKVStore<S>

fn get(&self, key: Key) -> Result<Option<Value>, KVStoreError>

Retrieve the value mapped from the given key.

fn atomic_write<'a>( &'a self, changes: Box<dyn Iterator<Item = (Key, Option<Value>)> + 'a>, ) -> Result<(), KVStoreError>

Write a batch of updates with atomicity to the store. Any changes written should be immediately visible in Self::get.