Struct AsyncLogger 

pub struct AsyncLogger { /* private fields */ }

Async wrapper that provides non-blocking logging.

Events are sent to a background task that handles the actual logging, allowing the caller to continue without waiting for I/O.

Implementations

impl AsyncLogger

pub fn new<L: AuditLogger + 'static>(inner: L, config: &AuditConfig) -> Self

Create a new async logger wrapping the given backend.

pub fn wrap<L: AuditLogger + 'static>(inner: L) -> Self

Create with default buffer size.

pub async fn shutdown(&self) -> Result<(), AuditError>

Gracefully shutdown the logger.

Trait Implementations

impl AuditLogger for AsyncLogger

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

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

Log an audit event.

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

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

Flush any buffered events.

fn name(&self) -> &str

Get the logger name for identification.

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

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

Log multiple events in a batch.

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

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

Check if the logger is healthy.

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

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

Get statistics about logged events.

impl Drop for AsyncLogger

fn drop(&mut self)

Executes the destructor for this type.