Struct MonotonicDeleteEvent

pub struct MonotonicDeleteEvent {
    pub event_key: PointRange,
    pub new_epoch: HummockEpoch,
}

Assume that watermark1 is 5, watermark2 is 7, watermark3 is 11, delete ranges { [0, wmk1) in epoch1, [wmk1, wmk2) in epoch2, [wmk2, wmk3) in epoch3 } can be transformed into events below: { <0, +epoch1> <wmk1, -epoch1> <wmk1, +epoch2> <wmk2, -epoch2> <wmk2, +epoch3> <wmk3, -epoch3> } Then we can get monotonic events (they are in order by user key) as below: { <0, epoch1>, <wmk1, epoch2>, <wmk2, epoch3>, <wmk3, +inf> } which means that delete range of [0, wmk1) is epoch1, delete range of [wmk1, wmk2) if epoch2, etc. In this example, at the event key wmk1 (5), delete range changes from epoch1 to epoch2, thus the new epoch is epoch2. epoch2 will be used from the event key wmk1 (5) and till the next event key wmk2 (7) (not inclusive). If there is no range deletes between current event key and next event key, new_epoch will be HummockEpoch::MAX.

Fields

event_key: PointRange

new_epoch: HummockEpoch

Implementations

impl MonotonicDeleteEvent

pub fn encode(&self, buf: impl BufMut)

pub fn decode(buf: &mut &[u8]) -> Self

Trait Implementations

impl Clone for MonotonicDeleteEvent

fn clone(&self) -> MonotonicDeleteEvent

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for MonotonicDeleteEvent

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for MonotonicDeleteEvent

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for MonotonicDeleteEvent

fn eq(&self, other: &MonotonicDeleteEvent) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for MonotonicDeleteEvent

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Eq for MonotonicDeleteEvent

impl StructuralPartialEq for MonotonicDeleteEvent