Struct mz_persist::client::AtomicWriteBuilder
source · [−]pub struct AtomicWriteBuilder<'a> { /* private fields */ }Expand description
A buffer for staging a set of records to write atomically.
Feel free to think of this as a write-only transaction.
Implementations
sourceimpl AtomicWriteBuilder<'_>
impl AtomicWriteBuilder<'_>
sourcepub 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, i64)>,
I: IntoIterator<Item = T>,
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, i64)>,
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
Auto Trait Implementations
impl<'a> RefUnwindSafe for AtomicWriteBuilder<'a>
impl<'a> Send for AtomicWriteBuilder<'a>
impl<'a> Sync for AtomicWriteBuilder<'a>
impl<'a> Unpin for AtomicWriteBuilder<'a>
impl<'a> UnwindSafe for AtomicWriteBuilder<'a>
Blanket Implementations
sourceimpl<T> BorrowMut<T> for T where
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
sourceimpl<T> FutureExt for T
impl<T> FutureExt for T
sourcefn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
sourcefn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
sourceimpl<T> Instrument for T
impl<T> Instrument for T
sourcefn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
sourcefn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
sourceimpl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
sourcefn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message T in a tonic::Request
sourceimpl<T> WithSubscriber for T
impl<T> WithSubscriber for T
sourcefn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
Attaches the provided Subscriber to this type, returning a
WithDispatch wrapper. Read more
sourcefn with_current_subscriber(self) -> WithDispatch<Self>
fn with_current_subscriber(self) -> WithDispatch<Self>
Attaches the current default Subscriber to this type, returning a
WithDispatch wrapper. Read more