Struct WatermarkCheckpoint 

pub struct WatermarkCheckpoint { /* private fields */ }

A resumable scan. The cursor is an opaque store cursor for the ls range; the ceiling and minimum preserve the original scan-time bound.

Implementations

impl WatermarkCheckpoint

pub fn encode(&self) -> Vec<u8>

Stable binary form: version, partition length and bytes, scan ceiling, partial minimum, exact recovery markers, then opaque cursor bytes.

Panics

A checkpoint created for an invalid or oversized partition cannot encode.

pub fn decode(bytes: &[u8]) -> Result<Self, StoreError>

Decode a checkpoint supplied by the previous scan step.

Trait Implementations

impl Clone for WatermarkCheckpoint

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WatermarkCheckpoint

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

Formats the value using the given formatter.

impl Eq for WatermarkCheckpoint

impl PartialEq for WatermarkCheckpoint

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for WatermarkCheckpoint