Struct BatchProcessor 

pub struct BatchProcessor<S: SyncEngineRef> { /* private fields */ }

Accumulates CDC events and flushes to sync-engine in batches.

Implementations

impl<S: SyncEngineRef> BatchProcessor<S>

pub fn new(sync_engine: Arc<S>, peer_id: String, config: BatchConfig) -> Self

Create a new batch processor.

pub fn add(&mut self, event: CdcEvent)

Add a CDC event to the batch.

If the same key has a pending operation, the new one replaces it (latest wins).

pub fn should_flush(&self) -> bool

Check if the batch should be flushed.

pub fn len(&self) -> usize

Number of pending events.

pub fn is_empty(&self) -> bool

Check if batch is empty.

pub async fn flush(&mut self) -> Result<BatchResult>

Flush the batch to sync-engine.

1. Partition by operation type
2. Parallel is_current() checks for PUTs
3. Submit filtered PUTs and DELETEs