Struct FileAuditSink 

pub struct FileAuditSink { /* private fields */ }

A ready-to-use AuditSink that appends one tab-separated line per record to a file — a turnkey compliance trail with no external dependency.

Line format: ts_ms \t action \t app \t stream \t detail, newline-terminated. Writes happen on a blocking thread-pool task so the async audit worker never stalls on disk I/O. Pair it with an AuditPipeline (which is the Observer) on the engine builder:

use arcly_stream::audit::{AuditPipeline, FileAuditSink};
use std::sync::Arc;

let sink = Arc::new(FileAuditSink::open("/var/log/arcly/audit.log")?);
let pipeline = AuditPipeline::new(sink, 1024);
// engine = Engine::builder().observer(pipeline).build();

Implementations

impl FileAuditSink

pub fn open(path: impl AsRef<Path>) -> Result<Self>

Open (creating if absent, appending if present) the audit log at path.

Trait Implementations

impl AuditSink for FileAuditSink

fn write<'life0, 'async_trait>( &'life0 self, record: AuditRecord, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

Durably persist one record. Errors are the sink’s concern (retry/buffer).