Struct DeltaBatch 

pub struct DeltaBatch<K, V> {
    pub epoch: u64,
    pub entries: Vec<DeltaEntry<K, V>>,
}

A batch of delta entries for a single propagation epoch.

Micro-batching amortizes per-delta overhead and enables bulk processing optimizations (e.g., deduplicating multiple updates to the same key within one epoch).

Fields

epoch: u64

The epoch number (monotonically increasing).

entries: Vec<DeltaEntry<K, V>>

The delta entries in this batch, ordered by logical_time.

Implementations

impl<K: Eq + Hash, V> DeltaBatch<K, V>

pub fn new(epoch: u64) -> Self

Create an empty batch for the given epoch.

pub fn len(&self) -> usize

Number of entries in this batch.

pub fn is_empty(&self) -> bool

Whether this batch is empty.

pub fn insert(&mut self, key: K, value: V, logical_time: u64)

Push an insert entry.

pub fn delete(&mut self, key: K, logical_time: u64)

Push a delete entry.

Trait Implementations

impl<K: Clone, V: Clone> Clone for DeltaBatch<K, V>

fn clone(&self) -> DeltaBatch<K, V>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<K: Debug, V: Debug> Debug for DeltaBatch<K, V>

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

Formats the value using the given formatter.