Struct AuditStore 

pub struct AuditStore { /* private fields */ }

Lightweight audit logging that reuses the event bus. All audit records are stored as events in the reserved _envoy_audit project.

Implementations

impl AuditStore

pub fn new() -> Self

pub fn log_message( &self, graph: &SqliteGraph, from: &str, to: &str, msg_type: MessageType, msg_id: &str, task_id: Option<&str>, ) -> Result<()>

Log that a message was sent.

pub fn log_event_ingested( &self, graph: &SqliteGraph, project: &str, source: &str, event_type: EventType, ) -> Result<()>

Log that an event was ingested.

pub fn log_agent_registered( &self, graph: &SqliteGraph, agent_id: &str, name: &str, kind: &str, ) -> Result<()>

Log agent registration.

pub fn log_agent_disconnected( &self, graph: &SqliteGraph, agent_id: &str, ) -> Result<()>

Log agent disconnection.

pub fn log_circuit_opened( &self, graph: &SqliteGraph, agent_id: &str, failure_count: u32, ) -> Result<()>

Log circuit breaker opened.

pub fn log_circuit_closed( &self, graph: &SqliteGraph, agent_id: &str, ) -> Result<()>

Log circuit breaker closed.

pub fn log_task_claimed( &self, graph: &SqliteGraph, task_id: &str, agent_id: &str, ) -> Result<()>

Log a task claim.

pub fn query( &self, graph: &SqliteGraph, agent_id: Option<&str>, operation: Option<&str>, task_id: Option<&str>, since: Option<&str>, limit: Option<i64>, ) -> Result<Vec<EnvoyEvent>>

Query audit records.

Trait Implementations

impl Default for AuditStore

fn default() -> Self

Returns the “default value” for a type.