Struct CompactionAuditSink 

pub struct CompactionAuditSink { /* private fields */ }

Async bounded-mpsc audit sink for compaction records.

The sink serialises CompactedPageRecord values to a JSONL file via a background writer task, mirroring the zeph-tools audit pattern. Dropped records (when the channel is full) are counted and logged.

Invariant

The sink MUST be flushed (all pending records written) before the compacted context is passed to the LLM. Callers use CompactionAuditSink::flush to ensure this.

Examples

use zeph_context::typed_page::CompactionAuditSink;
use std::path::Path;

let sink = CompactionAuditSink::open(Path::new(".local/audit/compaction.jsonl"), 256)
    .await
    .unwrap();

Implementations

impl CompactionAuditSink

pub async fn open(path: &Path, capacity: usize) -> Result<Self, Error>

Open a new audit sink writing to path.

capacity is the bounded channel depth; records dropped when full are counted in the internal drop counter and logged at WARN.

Errors

Returns an error when path cannot be opened for appending.

pub fn send(&self, record: CompactedPageRecord)

Send a record to the audit sink.

If the channel is full the record is dropped and the drop counter is incremented.

pub async fn flush(&self)

Flush all pending records by sending a sentinel and waiting for the writer task to drain. This uses a one-shot pair through the same channel ordering.

The implementation closes a clone’s sender so the channel drains; callers that need precise “before-LLM” semantics should call this before constructing the LLM request.

Note

In the current bounded-mpsc design, flush is a best-effort operation: records already accepted into the channel will be written, but there is no synchronous confirmation from the writer task. The audit invariant is therefore best-effort, not strict. A future revision may use a rendezvous channel for strict flush.

pub fn dropped_count(&self) -> u64

Number of records dropped due to a full channel.

Trait Implementations

impl Clone for CompactionAuditSink

fn clone(&self) -> CompactionAuditSink

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for CompactionAuditSink

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.