Struct InMemoryEventQueue 

pub struct InMemoryEventQueue { /* private fields */ }

Bounded FIFO event buffer with Send + Sync access.

Capacity defaults to 10_000; oldest events are dropped past that. Use PersistentEventQueue when surviving process restart matters.

Implementations

impl InMemoryEventQueue

pub fn new() -> Self

pub fn with_capacity(capacity: usize) -> Self

Trait Implementations

impl Debug for InMemoryEventQueue

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

Formats the value using the given formatter.

impl Default for InMemoryEventQueue

fn default() -> Self

Returns the “default value” for a type.

impl EventQueue for InMemoryEventQueue

fn push(&self, event: OwnedEvent)

Append an event to the tail. If the queue is at capacity, the oldest entry is dropped (FIFO eviction).

fn len(&self) -> usize

Number of events currently buffered. Includes events queued for retry.

fn drain_batch(&self, n: usize) -> Vec<OwnedEvent>

Take up to n events from the head, removing them. Used by adapter workers to assemble batches for HTTP transmission.

fn discard_all(&self)

Drop everything without sending. Called on consent revocation and on UsageReporter::erase_remote_data. Implementations MUST guarantee no buffered event escapes after this returns.

fn peek_recent(&self, n: usize) -> Vec<OwnedEvent>

Snapshot the head of the queue (clone). Used by the PrivacySettings “Inspect data sent” view. Best-effort — the returned events may have been drained by the time the caller reads them.

fn is_empty(&self) -> bool