Struct persist::client::AtomicWriteBuilder

pub struct AtomicWriteBuilder<'a> {
    stream_ids: &'a HashSet<Id>,
    records: Vec<(Id, ColumnarRecords)>,
}

A buffer for staging a set of records to write atomically.

Feel free to think of this as a write-only transaction.

Fields

stream_ids: &'a HashSet<Id>

records: Vec<(Id, ColumnarRecords)>

Implementations

impl AtomicWriteBuilder<'_>

pub fn add_write<K, V, T, I>(
    &mut self,
    handle: &StreamWriteHandle<K, V>,
    updates: I
) -> Result<(), Error> where
    K: Codec,
    V: Codec,
    T: Borrow<((K, V), u64, isize)>,
    I: IntoIterator<Item = T>, 

Adds the given updates to the set that will be written atomically.

Streams may be duplicated. However, the updates are passed down to storage unchanged, so users should coalesce them when that’s not otherwise slower.

Trait Implementations

impl<'a> Debug for AtomicWriteBuilder<'a>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.