Struct MemoryKVVStore

pub struct MemoryKVVStore { /* private fields */ }

A key-version-value in-memory store.

Implementations

impl MemoryKVVStore

pub fn new(signer_id: SignerId) -> Self

Create a new MemoryKVVStore

Trait Implementations

impl KVVStore for MemoryKVVStore

type Iter = Iter

fn put(&self, key: &str, value: Vec<u8>) -> Result<(), Error>

Put a key-value pair into the store

fn put_with_version( &self, key: &str, version: u64, value: Vec<u8>, ) -> Result<(), Error>

If the key already exists, the version must be greater than the existing version.

fn put_batch(&self, kvvs: Vec<KVV>) -> Result<(), Error>

Atomically put several KVVs into the store

fn get(&self, key: &str) -> Result<Option<(u64, Vec<u8>)>, Error>

Get a key-value pair from the store Returns Ok(None) if the key does not exist.

fn get_version(&self, key: &str) -> Result<Option<u64>, Error>

Get the version of a key-value pair from the store Returns Ok(None) if the key does not exist.

fn get_prefix(&self, prefix: &str) -> Result<Self::Iter, Error>

Get all key-value pairs with the given prefix

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

Delete a key-value pair from the store

fn clear_database(&self) -> Result<(), Error>

Clear the database

fn reset_versions(&self) -> Result<(), Error>

Reset the versions of all keys to 0, so that a replica can be initialized from scratch

fn signer_id(&self) -> SignerId

Get the signer ID

fn enter(&self) -> Result<(), Error>

Start a transaction

fn prepare(&self) -> Mutations

Get the commit log as a Mutations object, to be stored in the cloud

fn commit(&self) -> Result<(), Error>

Commit the commit log to the local KVVStore

fn put_batch_unlogged(&self, kvvs: Vec<KVV>) -> Result<(), Error>

Apply a batch from the cloud to the local store, without logging it

impl SendSync for MemoryKVVStore