Struct BatchBuilder 

pub struct BatchBuilder { /* private fields */ }

Builder for constructing batches of events with efficient serialization.

Implementations

impl BatchBuilder

pub const DEFAULT_MAX_EVENTS: usize = 1000

Default maximum events per batch.

pub const DEFAULT_MAX_BYTES: usize = 1_000_000

Default maximum bytes per batch (1MB).

pub fn new() -> Self

Create a new batch builder with default limits.

pub fn source_id(self, id: impl Into<String>) -> Self

Set the source ID.

pub fn batch_seq(self, seq: u64) -> Self

Set the batch sequence number.

pub fn max_events(self, max: usize) -> Self

Set the maximum number of events per batch.

pub fn max_bytes(self, max: usize) -> Self

Set the maximum bytes per batch.

pub fn add_event(&mut self, event: DatabaseEvent) -> Option<DatabaseEventBatch>

Add an event to the batch. Returns Some(batch) if the batch is full and was flushed.

pub fn add_relation(&mut self, meta: RelationMeta)

Add relation metadata to the batch.

pub fn is_empty(&self) -> bool

Check if the batch is empty.

pub fn len(&self) -> usize

Get the current number of events.

pub fn flush(&mut self) -> DatabaseEventBatch

Flush the current batch and return it.

pub fn finish(self) -> Option<DatabaseEventBatch>

Finish building and return any remaining events as a batch.

Trait Implementations

impl Default for BatchBuilder

fn default() -> Self

Returns the “default value” for a type.