Struct PgDmarcStore 

pub struct PgDmarcStore { /* private fields */ }

Postgres-backed DmarcStore. Expects a table:

CREATE TABLE dmarc_results (
  source_ip   text NOT NULL,
  from_domain text NOT NULL,
  spf_result  text NOT NULL,
  dkim_result text NOT NULL,
  dmarc_result text NOT NULL,
  disposition text NOT NULL,
  report_date date NOT NULL DEFAULT CURRENT_DATE
);
CREATE INDEX dmarc_results_by_date ON dmarc_results(report_date);

Implementations

impl PgDmarcStore

pub fn new(pool: PgPool) -> Self

Construct a PgDmarcStore from an existing pool. The caller owns the pool lifecycle.

Trait Implementations

impl DmarcStore for PgDmarcStore

type Error = Error

Backend-specific error type returned by every trait method.

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

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

Append a verified result. Called per-message during inbound.

fn get_results_for_date<'life0, 'life1, 'async_trait>( &'life0 self, date: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<DmarcResultRecord>, Error>> + Send + 'async_trait>>

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

Fetch all results recorded on date (YYYY-MM-DD). Called once per day by the report generator.

fn cleanup_old<'life0, 'async_trait>( &'life0 self, days: i64, ) -> Pin<Box<dyn Future<Output = Result<u64, Error>> + Send + 'async_trait>>

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

Prune results older than days. Called periodically.