pub struct CdcEvent {
pub seq: u64,
pub timestamp_ms: u64,
pub op: CdcOp,
pub key: Vec<u8>,
pub value: Option<Vec<u8>>,
}Expand description
A single captured mutation event.
Every write operation in a shard produces one CdcEvent. Events are
immutable once written to the ring and are identified by their unique,
monotonically increasing seq.
Fields§
§seq: u64Unique, monotonically increasing sequence number assigned at write time.
timestamp_ms: u64Wall-clock timestamp in milliseconds provided by the caller.
op: CdcOpThe kind of mutation that occurred.
key: Vec<u8>The affected key. Empty for CdcOp::FlushDb.
value: Option<Vec<u8>>The new value, when the operation carries one (e.g. Set, HSet).
Trait Implementations§
Auto Trait Implementations§
impl Freeze for CdcEvent
impl RefUnwindSafe for CdcEvent
impl Send for CdcEvent
impl Sync for CdcEvent
impl Unpin for CdcEvent
impl UnsafeUnpin for CdcEvent
impl UnwindSafe for CdcEvent
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