Struct PerfReader 

pub struct PerfReader { /* private fields */ }

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

Implementations

impl PerfReader

pub fn connect(db_url: &str) -> Result<Self>

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

Errors

Returns an error if db_url is not a postgres:// URL or the pool cannot be created. (Connection failures surface lazily on first query.)

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.