Module mz_persist::client
source · [−]Expand description
The public “async API” for persist.
Structs
A buffer for staging a set of records to write atomically.
A consistent snapshot of all data currently stored for an id, with keys and vals decoded.
An Iterator representing one part of the data in a DecodedSnapshot.
A handle for writing to multiple streams.
A clone-able handle to the persistence runtime.
A clone-able handle to the read-only persistence runtime.
A handle for a persisted stream of ((Key, Value), Time, i64) updates backed by an crate::indexed::Indexed via a RuntimeClient.
A handle that allows writes of ((Key, Value), Time, i64) updates into an crate::indexed::Indexed via a RuntimeClient.
A handle to construct a ColumnarRecords from a vector of records for writes.