Struct BatchedEventAppender 

pub struct BatchedEventAppender { /* private fields */ }

Batched event appender: groups events and submits in batches.

Implementations

impl BatchedEventAppender

pub fn spawn(batch_size: usize) -> (Self, ReceiverHandle)

Spawn the background batch flusher.

pub fn append(&self, event: DomainEvent)

Add an event to the batch buffer. Flushes when buffer is full.

pub fn flush(&self)

Flush remaining events.

pub fn pending(&self) -> usize

Pending events in the buffer.