Struct PgStatsRepository 

pub struct PgStatsRepository { /* private fields */ }

Implementations

impl PgStatsRepository

pub fn new(pool: PgPool) -> Self

pub async fn schema_overview(&self) -> Result<RelationalSchema, DomainError>

Every table in the user schema with its columns, for the lab’s schema browser and SQL-editor click-to-insert sidebar. _sqlx_migrations is sqlx’s own bookkeeping table and is filtered out.

pub async fn database_size(&self) -> Result<DatabaseSize, DomainError>

pub async fn table_stats( &self, limit: i64, offset: i64, ) -> Result<Vec<TableStats>, DomainError>

pub async fn index_stats( &self, limit: i64, ) -> Result<Vec<IndexStats>, DomainError>

pub async fn activity(&self, limit: i64) -> Result<Vec<Activity>, DomainError>

pub async fn blocking_locks(&self) -> Result<Vec<BlockingLock>, DomainError>

pub async fn has_pg_stat_statements(&self) -> Result<bool, DomainError>

Returns true when the pg_stat_statements extension is installed. Cheap (a single index lookup against pg_extension); callers should check this before calling Self::slow_queries.

pub async fn table_schema( &self, name: &str, ) -> Result<Option<TableSchema>, DomainError>

Full schema introspection for a single relation. Returns None when the table doesn’t exist (or isn’t a relation/matview/ partitioned table). Each query is one indexed catalog lookup, fine for an on-demand drill-down view.

pub async fn slow_queries( &self, limit: i64, ) -> Result<Vec<SlowQuery>, DomainError>

Trait Implementations

impl Clone for PgStatsRepository

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl DbStats for PgStatsRepository

The introspection capability, delegating to the inherent query methods. Explicit PgStatsRepository::method(self, ...) paths avoid resolving back to the trait method and recursing.

fn schema_overview<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<RelationalSchema, DomainError>> + Send + 'async_trait>>

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

Every browsable table with its columns, for the schema sidebar.

fn database_size<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<DatabaseSize, DomainError>> + Send + 'async_trait>>

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

fn table_stats<'life0, 'async_trait>( &'life0 self, limit: i64, offset: i64, ) -> Pin<Box<dyn Future<Output = Result<Vec<TableStats>, DomainError>> + Send + 'async_trait>>

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

fn index_stats<'life0, 'async_trait>( &'life0 self, limit: i64, ) -> Pin<Box<dyn Future<Output = Result<Vec<IndexStats>, DomainError>> + Send + 'async_trait>>

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

fn activity<'life0, 'async_trait>( &'life0 self, limit: i64, ) -> Pin<Box<dyn Future<Output = Result<Vec<Activity>, DomainError>> + Send + 'async_trait>>

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

fn blocking_locks<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<BlockingLock>, DomainError>> + Send + 'async_trait>>

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

fn table_schema<'life0, 'life1, 'async_trait>( &'life0 self, name: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<TableSchema>, DomainError>> + Send + 'async_trait>>

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

fn has_slow_query_stats<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<bool, DomainError>> + Send + 'async_trait>>

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

Whether per-statement timing (and therefore Self::slow_queries) is available on this engine right now.

fn slow_queries<'life0, 'async_trait>( &'life0 self, limit: i64, ) -> Pin<Box<dyn Future<Output = Result<Vec<SlowQuery>, DomainError>> + Send + 'async_trait>>

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

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

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

Run the engine’s routine optimize/refresh-statistics maintenance (SQLite VACUUM/ANALYZE, Postgres ANALYZE). The default is a no-op so a backend without a meaningful action need not implement it; the lab UI gates the button on the backend reporting one.