Struct PostgresStore 

pub struct PostgresStore { /* private fields */ }

PostgreSQL storage backend for baselines.

Implementations

impl PostgresStore

pub async fn new( url: &str, artifacts: Option<Arc<dyn ArtifactStore>>, pool_config: &PostgresPoolConfig, ) -> Result<Self, StoreError>

Creates a new PostgreSQL storage backend and runs initial schema migrations.

The connection pool is configured according to the supplied PostgresPoolConfig. An after_connect callback sets statement_timeout on every new connection, and a before_acquire callback pings the connection to verify it is still alive.

Trait Implementations

impl AuditStore for PostgresStore

fn log_event<'life0, 'life1, 'async_trait>( &'life0 self, event: &'life1 AuditEvent, ) -> Pin<Box<dyn Future<Output = Result<(), StoreError>> + Send + 'async_trait>>

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

Appends a new audit event to the log.

fn list_events<'life0, 'life1, 'async_trait>( &'life0 self, query: &'life1 ListAuditEventsQuery, ) -> Pin<Box<dyn Future<Output = Result<ListAuditEventsResponse, StoreError>> + Send + 'async_trait>>

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

Lists audit events with optional filtering.

impl BaselineStore for PostgresStore

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

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

Stores a new baseline record.

fn get<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, project: &'life1 str, benchmark: &'life2 str, version: &'life3 str, ) -> Pin<Box<dyn Future<Output = Result<Option<BaselineRecord>, StoreError>> + Send + 'async_trait>>

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

Retrieves a baseline by project, benchmark, and version.

fn get_latest<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, project: &'life1 str, benchmark: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<Option<BaselineRecord>, StoreError>> + Send + 'async_trait>>

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

Retrieves the latest baseline for a project and benchmark.

fn list<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, project: &'life1 str, query: &'life2 ListBaselinesQuery, ) -> Pin<Box<dyn Future<Output = Result<ListBaselinesResponse, StoreError>> + Send + 'async_trait>>

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

Lists baselines with optional filtering.

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

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

Updates an existing baseline record.

fn delete<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, project: &'life1 str, benchmark: &'life2 str, version: &'life3 str, ) -> Pin<Box<dyn Future<Output = Result<bool, StoreError>> + Send + 'async_trait>>

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

Deletes a baseline (soft delete).

fn hard_delete<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, project: &'life1 str, benchmark: &'life2 str, version: &'life3 str, ) -> Pin<Box<dyn Future<Output = Result<bool, StoreError>> + Send + 'async_trait>>

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

Permanently removes a deleted baseline.

fn list_versions<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, project: &'life1 str, benchmark: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<BaselineVersion>, StoreError>> + Send + 'async_trait>>

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

Lists all versions for a benchmark.

fn health_check<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<StorageHealth, StoreError>> + Send + 'async_trait>>

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

Checks if the storage backend is healthy.

fn backend_type(&self) -> &'static str

Returns the backend type name.

fn pool_metrics(&self) -> Option<PoolMetrics>

Returns connection pool metrics, if the backend uses a pool.

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

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

Stores a new verdict record.

fn list_verdicts<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, project: &'life1 str, query: &'life2 ListVerdictsQuery, ) -> Pin<Box<dyn Future<Output = Result<ListVerdictsResponse, StoreError>> + Send + 'async_trait>>

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

Lists verdicts with optional filtering.

impl Clone for PostgresStore

fn clone(&self) -> PostgresStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PostgresStore

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.