Struct PgDovecoteAudit 

pub struct PgDovecoteAudit { /* private fields */ }

Postgres Dovecote-backed decision audit sink.

Implementations

impl PgDovecoteAudit

pub fn new( pool: PgPool, source: impl Into<String>, ) -> Result<Self, DecisionAuditConfigError>

Creates a sink using an application-owned absolute source URI.

Errors

Returns an error when source is not an absolute URI.

pub fn from_config(pool: PgPool, config: DecisionAuditConfig) -> Self

Creates a sink from validated configuration.

pub const fn config(&self) -> &DecisionAuditConfig

Returns the configuration used for newly constructed events.

pub async fn check_schema(&self) -> Result<(), SchemaError>

Verifies that the selected database has the installed Dovecote schema.

Errors

Returns the typed Dovecote schema error when the schema is absent or incompatible.

pub async fn record_authorization_attempt( &self, entry: &AuthorizationAttempt, ) -> Result<EnqueueOutcome, PgDovecoteAuditError>

Stores a failed attempt in its own transaction.

Errors

Returns event validation, enqueue or commit errors. Retain the same immutable entry when reconciling an uncertain commit.

pub async fn record_attempt_in_transaction( &self, transaction: &mut Transaction<'_, Postgres>, entry: &AuthorizationAttempt, ) -> Result<EnqueueOutcome, PgDovecoteAuditError>

Stores a failed attempt in a caller-owned transaction.

Errors

Returns event or enqueue failures. The caller must commit for durability; rolling back the protected operation also rolls back this audit event.

pub async fn record_decision_audit( &self, entry: &AuditEntry, ) -> Result<EnqueueOutcome, PgDovecoteAuditError>

Records an audit event in a transaction owned by this sink.

This is atomic between the Dovecote event and its pending delivery. Use Self::record_decision_audit_in_transaction when an application must include the event in its own transaction boundary.

Errors

Returns a typed event, Dovecote, or SQLx transaction error.

pub async fn record_decision_audit_in_transaction( &self, transaction: &mut Transaction<'_, Postgres>, entry: &AuditEntry, ) -> Result<EnqueueOutcome, PgDovecoteAuditError>

Records an audit event in a caller-owned Postgres transaction.

The caller must commit or roll back the transaction. The operation is atomic with other writes in that transaction, but not with arbitrary business-state writes performed in another transaction.

Errors

Returns a typed event or Dovecote error. The caller remains responsible for rolling back after an error.

Trait Implementations

impl AttemptAuditSink for PgDovecoteAudit

type Error = PgDovecoteAuditError

Storage failure, including uncertain commit outcomes.

fn record_attempt<'life0, 'life1, 'async_trait>( &'life0 self, entry: &'life1 AuthorizationAttempt, ) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>>

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

Stores the frozen attempt; retry exactly this event after ambiguous errors.

impl AuditSink for PgDovecoteAudit

type Error = PgDovecoteAuditError

Sink-specific write error.

fn record<'life0, 'life1, 'async_trait>( &'life0 self, entry: &'life1 AuditEntry, ) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>>

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

Records a durable audit entry.

impl Clone for PgDovecoteAudit

fn clone(&self) -> PgDovecoteAudit

Returns a duplicate of the value.

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

Performs copy-assignment from source.