Struct PerfReader 

pub struct PerfReader { /* private fields */ }

A live PostgreSQL connection pool for reading the change-log contract view.

Implementations

impl PerfReader

pub async fn connect(db_url: &str, tls: &PostgresTlsConfig) -> Result<Self>

Connect to db_url (PostgreSQL only) for change-log reads.

Errors

Returns an error if db_url is not a PostgreSQL connection string (see crate::connection::require_postgres), the server cannot be reached, or it is older than PostgreSQL 18.

pub async fn db_now_epoch(&self) -> Result<f64>

The database clock as a Unix epoch in seconds — the reference the analysis windows back from, so there is no app↔DB skew at the window boundary.

Errors

Returns an error if the connection or the query fails.

pub async fn load_samples( &self, window_days: i32, object_type: Option<&str>, ) -> Result<Vec<ChangeLogSample>>

Load every change-log sample within the trailing window_days window, optionally restricted to a single object_type.

The window is applied in SQL (created_at >= now() - make_interval(days => $1)) so only the rows the analysis needs cross the wire.

Errors

Returns an error if the connection or the query fails.