Struct BatchProcessor 

pub struct BatchProcessor { /* private fields */ }

Batch processor for aggregating events before transmission.

Implementations

impl BatchProcessor

pub fn new(max_size: usize, max_age: Duration) -> Self

Create a new batch processor.

pub fn from_config(config: &BufferConfig) -> Self

Create from buffer configuration.

pub async fn add(&self, event: UdmEvent) -> Option<Vec<UdmEvent>>

Add an event to the batch.

Returns Some(events) if the batch is ready to be sent.

pub async fn add_many(&self, new_events: Vec<UdmEvent>) -> Vec<Vec<UdmEvent>>

Add multiple events.

Returns batches ready to be sent (may return multiple if events exceed batch size).

pub async fn should_flush(&self) -> bool

Check if the batch should be flushed.

pub async fn flush(&self) -> Vec<UdmEvent>

Flush the current batch regardless of conditions.

pub async fn len(&self) -> usize

Get current batch size.

pub async fn is_empty(&self) -> bool

Check if batch is empty.

pub async fn age(&self) -> Duration

Get age of current batch.

pub async fn send_batch<T: Transport>( &self, transport: &T, ) -> PhyTraceResult<Option<BatchResult>>

Send the batch using a transport.

Trait Implementations

impl Debug for BatchProcessor

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

Formats the value using the given formatter.