Struct FileAuditSink 

pub struct FileAuditSink { /* private fields */ }

Available on crate feature auth only.

File-based audit sink that writes JSONL (one JSON line per event).

Supports optional cryptographic chaining — when enabled, each event includes the SHA-256 hash of the previous event’s JSON representation, creating an append-only tamper-evident log.

Implementations

impl FileAuditSink

pub fn new(path: impl Into<PathBuf>) -> Result<FileAuditSink, Error>

Create a new file audit sink.

pub fn with_chaining(path: impl Into<PathBuf>) -> Result<FileAuditSink, Error>

Create a new file audit sink with cryptographic hash chaining enabled.

Each event will include a prev_hash field containing the SHA-256 hash of the previous event’s JSON, creating a tamper-evident append-only log.

pub fn path(&self) -> &PathBuf

Get the path to the audit log file.

Trait Implementations

impl AuditSink for FileAuditSink

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

where 'life0: 'async_trait, FileAuditSink: '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 'life0: 'async_trait, Self: '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 'life0: 'async_trait, 'life1: 'async_trait, Self: '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 'life0: 'async_trait, Self: '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 'life0: 'async_trait, Self: 'async_trait,

Flush any buffered events to the underlying storage.