Struct AuditBatch 

pub struct AuditBatch { /* private fields */ }

The batch owner. Constructed once per configured EventStore; every dispatch-audit call site routes its row through AuditBatch::submit instead of taking its own writer-task acquisition.

Implementations

impl AuditBatch

pub fn new(store: Arc<dyn EventStore>, config: AuditBatchConfig) -> Arc<Self>

pub fn health_metrics(&self) -> AuditBatchHealthMetrics

Process-lifetime audit-batch health counters, for the registry/ runtime owner to feed into db_diagnostics (D8’s operator surface). Unlike test_internals::AuditBatchSnapshot::metrics_snapshot, which is test-only (the module is cfg-gated and invisible to the default doc build, so an intra-doc link cannot resolve), this is always available.

Trait Implementations

impl AuditBatchControl for AuditBatch

fn submit<'life0, 'async_trait>( &'life0 self, row: PreparedAuditRow, ) -> Pin<Box<dyn Future<Output = Result<AuditCommitOutcome, AuditTerminalReason>> + Send + 'async_trait>>

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

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

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

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

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