Struct InMemoryAuditSink 

pub struct InMemoryAuditSink { /* private fields */ }

In-memory audit sink for testing and development.

Stores all events in a Vec behind a RwLock. Supports querying and purging. Not suitable for production — use FileAuditSink or a database sink instead.

Implementations

impl InMemoryAuditSink

pub fn new() -> Self

Create a new in-memory audit sink.

pub async fn len(&self) -> usize

Get the number of stored events.

pub async fn is_empty(&self) -> bool

Check if the sink is empty.

Trait Implementations

impl AuditSink for InMemoryAuditSink

fn log<'life0, 'async_trait>( &'life0 self, event: AuditEvent, ) -> Pin<Box<dyn Future<Output = Result<(), AuthError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Log a single audit event.

fn log_batch<'life0, 'async_trait>( &'life0 self, events: Vec<AuditEvent>, ) -> Pin<Box<dyn Future<Output = Result<(), AuthError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Log a batch of audit events atomically.

fn query<'life0, 'life1, 'async_trait>( &'life0 self, filter: &'life1 AuditFilter, ) -> Pin<Box<dyn Future<Output = Result<Vec<AuditEvent>, AuthError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Query audit events matching the given filter.

fn purge_before<'life0, 'async_trait>( &'life0 self, cutoff: DateTime<Utc>, ) -> Pin<Box<dyn Future<Output = Result<u64, AuthError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Purge events older than the given cutoff timestamp.

fn flush<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), AuthError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Flush any buffered events to the underlying storage.

impl Default for InMemoryAuditSink

fn default() -> Self

Returns the “default value” for a type.