Struct BatchAccumulator 

pub struct BatchAccumulator { /* private fields */ }

Accumulates CRDT operations for batched transmission

Implementations

impl BatchAccumulator

pub fn new(config: BatchConfig) -> Self

Create a new accumulator with the given config

pub fn with_defaults() -> Self

Create with default config

pub fn add(&mut self, op: CrdtOperation, current_time_ms: u64) -> bool

Add an operation to the batch

Returns true if the operation was added, false if batch is full

pub fn should_flush(&self, current_time_ms: u64) -> bool

Check if the batch should be flushed

pub fn flush(&mut self, current_time_ms: u64) -> Option<OperationBatch>

Flush pending operations into a batch

pub fn force_flush(&mut self, current_time_ms: u64) -> Option<OperationBatch>

Force flush regardless of timing constraints

pub fn pending_count(&self) -> usize

Get number of pending operations

pub fn accumulated_bytes(&self) -> usize

Get accumulated bytes

pub fn has_pending(&self) -> bool

Check if there are pending operations

pub fn clear(&mut self)

Clear all pending operations without flushing

pub fn config(&self) -> &BatchConfig

Get the config

pub fn set_config(&mut self, config: BatchConfig)

Update the config

Trait Implementations

impl Debug for BatchAccumulator

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

Formats the value using the given formatter.