Struct AuditLogger 

pub struct AuditLogger<R: AuditEventRepository> { /* private fields */ }

AuditLogger service for simplified audit event recording

This service provides a convenient API for recording audit events from application code and middleware. It handles:

• Automatic context extraction from HTTP requests
• Actor detection from authentication context
• Async, non-blocking logging
• Error handling (audit failures are logged but don’t break requests)

Example

let audit_logger = AuditLogger::new(audit_repo);

audit_logger.log(
    tenant_id,
    AuditAction::EventIngested,
    Actor::api_key("key-123".to_string(), "prod-api-key".to_string()),
)
.with_resource("event_stream".to_string(), "stream-456".to_string())
.with_context(request_context)
.record_async()
.await;

Implementations

impl<R: AuditEventRepository> AuditLogger<R>

pub fn new(repository: Arc<R>) -> Self

Create a new AuditLogger with the given repository

pub fn log( &self, tenant_id: TenantId, action: AuditAction, actor: Actor, ) -> AuditLogEntry<'_, R>

Start building an audit log entry

pub async fn log_success( &self, tenant_id: TenantId, action: AuditAction, actor: Actor, ) -> Result<(), AllSourceError>

Log a successful event (convenience method)

pub async fn log_failure( &self, tenant_id: TenantId, action: AuditAction, actor: Actor, error_message: String, ) -> Result<(), AllSourceError>

Log a failed event (convenience method)

pub async fn log_resource_action( &self, tenant_id: TenantId, action: AuditAction, actor: Actor, resource_type: String, resource_id: String, outcome: AuditOutcome, ) -> Result<(), AllSourceError>

Log an event with resource information (convenience method)

pub async fn record_silently(&self, event: AuditEvent)

Record an event without returning an error (logs errors internally) This is useful for middleware where audit failures shouldn’t break requests

pub async fn log_batch( &self, events: Vec<AuditEvent>, ) -> Result<(), AllSourceError>

Batch log multiple events

pub async fn log_batch_silently(&self, events: Vec<AuditEvent>)

Batch log multiple events without returning an error