pub enum CommitMutation {
Append {
path: StreamPath,
records: Vec<Bytes>,
},
Fork {
source: StreamPath,
destination: StreamPath,
at_tail: u64,
},
Trim {
path: StreamPath,
before: u64,
},
Delete {
path: StreamPath,
},
}Expand description
Mutation in one coordinated commit.
Variants§
Append
Append one nonempty batch.
Fork
Fork one pre-commit prefix.
Trim
Advance one path’s logical trim point.
Delete
Permanently retire one path.
Fields
§
path: StreamPathExisting path without live descendants.
Trait Implementations§
Source§impl Clone for CommitMutation
impl Clone for CommitMutation
Source§impl Debug for CommitMutation
impl Debug for CommitMutation
impl Eq for CommitMutation
Source§impl PartialEq for CommitMutation
impl PartialEq for CommitMutation
impl StructuralPartialEq for CommitMutation
Auto Trait Implementations§
impl Freeze for CommitMutation
impl RefUnwindSafe for CommitMutation
impl Send for CommitMutation
impl Sync for CommitMutation
impl Unpin for CommitMutation
impl UnsafeUnpin for CommitMutation
impl UnwindSafe for CommitMutation
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
Source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
Source§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
Compare self to
key and return true if they are equal.Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
Source§fn in_current_span(self) -> Instrumented<Self> ⓘ
fn in_current_span(self) -> Instrumented<Self> ⓘ
Source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request