Struct EventBuffer 

pub struct EventBuffer { /* private fields */ }

Lock-free ring buffer for allocation events

Uses single-producer, single-consumer (SPSC) design where the producer (allocator hook) runs on the application thread and the consumer (aggregator) runs on a dedicated background thread.

Implementations

impl EventBuffer

pub fn new() -> Self

Create new event buffer with default size

pub fn push(&self, event: AllocationEvent) -> AsyncResult<()>

Push event to buffer (producer side)

Returns Ok(()) if successful, Err with drop count if buffer full. Never blocks - drops events instead to maintain real-time performance.

pub fn pop(&self) -> Option<AllocationEvent>

Pop event from buffer (consumer side)

Returns Some(event) if available, None if buffer empty. Only called by the aggregator thread.

pub fn len(&self) -> usize

Get current number of events in buffer

pub fn is_empty(&self) -> bool

Check if buffer is empty

pub fn capacity(&self) -> usize

Get buffer capacity

pub fn dropped_count(&self) -> usize

Get number of dropped events

pub fn drain(&self) -> Vec<AllocationEvent>

Drain all events from buffer

Returns vector of all current events, clearing the buffer. Used for bulk processing and testing.

Trait Implementations

impl Default for EventBuffer

fn default() -> Self

Returns the “default value” for a type.

impl Send for EventBuffer

impl Sync for EventBuffer