Struct AuditPipeline 

pub struct AuditPipeline { /* private fields */ }

Lock-free front door for audit records.

Not #[Injectable] — provide via ctx.provide(AuditPipeline::new(...)). When absent from the DI container, #[AuditLog] routes are a no-op.

Implementations

impl AuditPipeline

pub fn new( sink: Arc<dyn AuditSink>, capacity: usize, flush_batch: usize, ) -> Self

capacity bounds hot-path memory; flush_batch caps records per sink write. The worker drains greedily, so latency under light load is one scheduler tick, not a timer.

pub fn record(&self, rec: AuditRecord)

O(1), lock-free, never blocks. Drops (and counts) when the buffer is full rather than stalling request handling.