pub struct CommittedChange {
pub offset: u64,
pub term: u64,
pub seq_in_entry: u32,
pub cf: u32,
pub key: Vec<u8>,
pub op: String,
pub value: Vec<u8>,
pub is_snapshot: bool,
}Expand description
A single change delivered by crate::StateletClient::subscribe_committed.
offset is the stable Raft log index (the resume key). is_snapshot is
true for synthetic put changes produced by a bootstrap Scan after the
requested offset was compacted away; those all carry the same
snapshot_offset and term = 0 / seq_in_entry = 0.
Fields§
§offset: u64§term: u64§seq_in_entry: u32§cf: u32§key: Vec<u8>§op: String“put” | “delete” | “merge”
value: Vec<u8>§is_snapshot: boolTrait Implementations§
Source§impl Clone for CommittedChange
impl Clone for CommittedChange
Source§fn clone(&self) -> CommittedChange
fn clone(&self) -> CommittedChange
Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreSource§impl Debug for CommittedChange
impl Debug for CommittedChange
impl Eq for CommittedChange
Source§impl PartialEq for CommittedChange
impl PartialEq for CommittedChange
impl StructuralPartialEq for CommittedChange
Auto Trait Implementations§
impl Freeze for CommittedChange
impl RefUnwindSafe for CommittedChange
impl Send for CommittedChange
impl Sync for CommittedChange
impl Unpin for CommittedChange
impl UnsafeUnpin for CommittedChange
impl UnwindSafe for CommittedChange
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
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
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§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<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