Struct mz_stash::Transaction

pub struct Transaction<'a> { /* private fields */ }

Implementations

impl<'a> Transaction<'a>

pub async fn collection<K, V>( &self, name: &str ) -> Result<StashCollection<K, V>, StashError>

where K: Data, V: Data,

pub async fn collections(&self) -> Result<BTreeMap<i64, String>, StashError>

Returns the ids and names of all collections.

pub async fn iter<K, V>( &self, collection: StashCollection<K, V> ) -> Result<Vec<((K, V), Timestamp, Diff)>, StashError>

where K: Data, V: Data,

Iterates over a collection.

pub async fn peek_one<K, V>( &self, collection: StashCollection<K, V> ) -> Result<BTreeMap<K, V>, StashError>

where K: Data, V: Data,

Returns the current k,v pairs of sealed entries, erroring if there is more than one entry for a given key or the multiplicity is not 1 for each key.

Sealed entries are those with timestamps less than the collection’s upper frontier.

pub async fn peek_key_one<K, V>( &self, collection: StashCollection<K, V>, key: &K ) -> Result<Option<V>, StashError>

where K: Data, V: Data,

Returns the current sealed value for the given key, erroring if there is more than one entry for the key or its multiplicity is not 1.

Sealed entries are those with timestamps less than the collection’s upper frontier.

pub async fn append( &self, batches: Vec<AppendBatch> ) -> Result<BoxFuture<'static, ()>, StashError>

Applies batches to the current transaction. If any batch fails and in error returned, all other applications are rolled back.