Struct PersistentEventQueue 

pub struct PersistentEventQueue { /* private fields */ }

redb-backed event queue. Send + Sync — internal Mutex wraps the Database handle so adapter UI-thread pushes and worker- thread drains don’t conflict.

Implementations

impl PersistentEventQueue

pub fn open(path: impl Into<PathBuf>) -> Result<Self, PersistentQueueError>

Open or create the queue file at path. Parent directory is created if missing.

pub fn open_with( path: impl Into<PathBuf>, capacity: usize, max_age: Duration, ) -> Result<Self, PersistentQueueError>

Like open but with explicit capacity (events past which the oldest is dropped) and max_age (events older than this are dropped on next push or drain).

pub fn path(&self) -> &Path

Trait Implementations

impl Debug for PersistentEventQueue

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

Formats the value using the given formatter.

impl EventQueue for PersistentEventQueue

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 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 len(&self) -> usize

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

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