Struct AuditLog 

pub struct AuditLog { /* private fields */ }

An append-only, bounded audit log for coordinator state changes.

Thread-safety note: this struct is not internally synchronised. In a multi-threaded context, wrap it in Arc<Mutex<AuditLog>> or similar.

Implementations

impl AuditLog

pub fn new(config: AuditLogConfig) -> Self

Create a new audit log with the given configuration.

pub fn with_defaults() -> Self

Create a new audit log with default configuration.

pub fn append(&mut self, builder: AuditEntryBuilder) -> Option<u64>

Append an entry built from a builder.

Returns the assigned sequence number, or None if the event was filtered out by the minimum severity setting.

pub fn log_job_submitted( &mut self, job_id: Uuid, actor: &str, codec: &str, ) -> Option<u64>

Convenience: log a job submission.

pub fn log_job_cancelled( &mut self, job_id: Uuid, actor: &str, reason: &str, ) -> Option<u64>

Convenience: log a job cancellation.

pub fn log_job_failed( &mut self, job_id: Uuid, actor: &str, error: &str, ) -> Option<u64>

Convenience: log a job failure.

pub fn log_worker_joined(&mut self, worker_id: &str, addr: &str) -> Option<u64>

Convenience: log a worker joining the cluster.

pub fn log_worker_left(&mut self, worker_id: &str, reason: &str) -> Option<u64>

Convenience: log a worker leaving the cluster.

pub fn log_leader_elected(&mut self, leader_id: &str, term: u64) -> Option<u64>

Convenience: log a leader election.

pub fn len(&self) -> usize

Number of entries currently in the log.

pub fn is_empty(&self) -> bool

Whether the log is empty.

pub fn total_appended(&self) -> u64

Total entries ever appended (including evicted).

pub fn get_by_sequence(&self, seq: u64) -> Option<&AuditEntry>

Get an entry by sequence number.

pub fn recent(&self, n: usize) -> Vec<&AuditEntry>

Return the most recent n entries (newest last).

pub fn query_by_kind(&self, kind: AuditEventKind) -> Vec<&AuditEntry>

Query entries by event kind.

pub fn query_by_actor(&self, actor: &str) -> Vec<&AuditEntry>

Query entries by actor.

pub fn query_by_target(&self, target: &str) -> Vec<&AuditEntry>

Query entries by target.

pub fn query_by_min_severity(&self, min: AuditSeverity) -> Vec<&AuditEntry>

Query entries by severity at or above the given level.

pub fn query_by_time_range( &self, start_us: u64, end_us: u64, ) -> Vec<&AuditEntry>

Query entries within a time range (microseconds since Unix epoch).

pub fn clear(&mut self)

Clear all entries.

pub fn export_all(&self) -> Vec<AuditEntry>

Export all entries as a vector (for serialization or transfer).