Struct DeltaBatch 

pub struct DeltaBatch {
    pub deltas: Vec<StateDelta>,
    pub combined_clock: VectorClock,
}

A batch of deltas that can be applied together.

Batching reduces network overhead when multiple deltas need to be transmitted.

Fields

deltas: Vec<StateDelta>

The deltas in this batch, in causal order

combined_clock: VectorClock

Combined clock covering all deltas

Implementations

impl DeltaBatch

pub fn new() -> Self

Create a new empty batch.

pub fn push(&mut self, delta: StateDelta)

Add a delta to the batch.

pub fn is_empty(&self) -> bool

Check if the batch is empty.

pub fn len(&self) -> usize

Get the number of deltas in the batch.

pub fn combine_additive(&self) -> Option<GA3>

Combine all additive deltas into a single delta.

This only works for additive deltas; mixed batches are not combined.

pub fn apply_to(&self, state: &mut GA3)

Apply all deltas in the batch to a state.

pub fn estimated_size(&self) -> usize

Get the estimated total size in bytes.

Trait Implementations

impl Clone for DeltaBatch

fn clone(&self) -> DeltaBatch

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DeltaBatch

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

Formats the value using the given formatter.

impl Default for DeltaBatch

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for DeltaBatch

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for DeltaBatch

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

where __S: Serializer,

Serialize this value into the given Serde serializer.