diff --git a/internal/collector/eq_pg16_metrics.yaml b/internal/collector/eq_pg16_fast_metrics.yaml
similarity index 90%
rename from internal/collector/eq_pg16_metrics.yaml
rename to internal/collector/eq_pg16_fast_metrics.yaml
index 2abc0e2208..855dc8a3d3 100644
--- a/internal/collector/eq_pg16_metrics.yaml
+++ b/internal/collector/eq_pg16_fast_metrics.yaml
@@ -4,6 +4,9 @@
 # https://github.com/open-telemetry/opentelemetry-collector-contrib/blob/-/receiver/sqlqueryreceiver#metrics-queries
 # https://github.com/CrunchyData/pgmonitor/blob/development/sql_exporter/common/crunchy_global_collector.yml
 
+# NOTE: Some of the columns below can return NULL values, for which sqlqueryreceiver will warn.
+# https://github.com/open-telemetry/opentelemetry-collector-contrib/tree/main/receiver/sqlqueryreceiver#null-values
+# Those columns are retained_bytes, database, and conflicting and we avoid NULL by using COALESCE.
   - sql: >
       SELECT
           s.slot_name
diff --git a/internal/collector/generated/eq_pg16_metrics.json b/internal/collector/generated/eq_pg16_fast_metrics.json
similarity index 100%
rename from internal/collector/generated/eq_pg16_metrics.json
rename to internal/collector/generated/eq_pg16_fast_metrics.json
diff --git a/internal/collector/generated/gte_pg16_metrics.json b/internal/collector/generated/gte_pg16_slow_metrics.json
similarity index 100%
rename from internal/collector/generated/gte_pg16_metrics.json
rename to internal/collector/generated/gte_pg16_slow_metrics.json
diff --git a/internal/collector/generated/gte_pg17_metrics.json b/internal/collector/generated/gte_pg17_fast_metrics.json
similarity index 100%
rename from internal/collector/generated/gte_pg17_metrics.json
rename to internal/collector/generated/gte_pg17_fast_metrics.json
diff --git a/internal/collector/generated/lt_pg16_fast_metrics.json b/internal/collector/generated/lt_pg16_fast_metrics.json
new file mode 100644
index 0000000000..dcd1d5fe77
--- /dev/null
+++ b/internal/collector/generated/lt_pg16_fast_metrics.json
@@ -0,0 +1 @@
+[{"metrics":[{"attribute_columns":["database","slot_name","slot_type"],"description":"Active state of slot. 1 = true. 0 = false.","metric_name":"ccp_replication_slots_active","static_attributes":{"server":"localhost:5432"},"value_column":"active"},{"attribute_columns":["database","slot_name","slot_type"],"description":"The amount of WAL (in bytes) being retained for this slot","metric_name":"ccp_replication_slots_retained_bytes","static_attributes":{"server":"localhost:5432"},"value_column":"retained_bytes"},{"attribute_columns":["database","slot_name","slot_type"],"description":"True if this logical slot conflicted with recovery (and so is now invalidated). When this column is true, check invalidation_reason column for the conflict reason. Always NULL for physical slots.","metric_name":"ccp_replication_slots_conflicting","static_attributes":{"server":"localhost:5432"},"value_column":"conflicting"},{"attribute_columns":["database","slot_name","slot_type"],"description":"True if this is a logical slot enabled to be synced to the standbys so that logical replication can be resumed from the new primary after failover. Always false for physical slots.","metric_name":"ccp_replication_slots_failover","static_attributes":{"server":"localhost:5432"},"value_column":"failover"},{"attribute_columns":["database","slot_name","slot_type"],"description":"True if this is a logical slot that was synced from a primary server. On a hot standby, the slots with the synced column marked as true can neither be used for logical decoding nor dropped manually. The value of this column has no meaning on the primary server; the column value on the primary is default false for all slots but may (if leftover from a promoted standby) also be true.","metric_name":"ccp_replication_slots_synced","static_attributes":{"server":"localhost:5432"},"value_column":"synced"}],"sql":"SELECT\n    s.slot_name\n    , s.active::int\n    , COALESCE(pg_wal_lsn_diff(CASE WHEN pg_is_in_recovery() THEN pg_last_wal_replay_lsn() ELSE pg_current_wal_insert_lsn() END, s.restart_lsn), 0) AS retained_bytes\n    , COALESCE(s.database, '')\n    , s.slot_type\n    , 0 AS conflicting\n    , 0 AS failover\n    , 0 AS synced\nFROM pg_catalog.pg_replication_slots s;\n"}]
diff --git a/internal/collector/generated/lt_pg16_metrics.json b/internal/collector/generated/lt_pg16_slow_metrics.json
similarity index 64%
rename from internal/collector/generated/lt_pg16_metrics.json
rename to internal/collector/generated/lt_pg16_slow_metrics.json
index acc1a5f30e..98bb0cc213 100644
--- a/internal/collector/generated/lt_pg16_metrics.json
+++ b/internal/collector/generated/lt_pg16_slow_metrics.json
@@ -1 +1 @@
-[{"metrics":[{"attribute_columns":["dbname","relname","schemaname"],"data_type":"sum","description":"Number of times this table has been manually analyzed","metric_name":"ccp_stat_user_tables_analyze_count","static_attributes":{"server":"localhost:5432"},"value_column":"analyze_count"},{"attribute_columns":["dbname","relname","schemaname"],"data_type":"sum","description":"Number of times this table has been analyzed by the autovacuum daemon","metric_name":"ccp_stat_user_tables_autoanalyze_count","static_attributes":{"server":"localhost:5432"},"value_column":"autoanalyze_count"},{"attribute_columns":["dbname","relname","schemaname"],"data_type":"sum","description":"Number of times this table has been vacuumed by the autovacuum daemon","metric_name":"ccp_stat_user_tables_autovacuum_count","static_attributes":{"server":"localhost:5432"},"value_column":"autovacuum_count"},{"attribute_columns":["dbname","relname","schemaname"],"data_type":"sum","description":"Number of index scans initiated on this table","metric_name":"ccp_stat_user_tables_idx_scan","static_attributes":{"server":"localhost:5432"},"value_column":"idx_scan"},{"attribute_columns":["dbname","relname","schemaname"],"data_type":"sum","description":"Number of live rows fetched by index scans","metric_name":"ccp_stat_user_tables_idx_tup_fetch","static_attributes":{"server":"localhost:5432"},"value_column":"idx_tup_fetch"},{"attribute_columns":["dbname","relname","schemaname"],"description":"Estimated number of dead rows","metric_name":"ccp_stat_user_tables_n_dead_tup","static_attributes":{"server":"localhost:5432"},"value_column":"n_dead_tup"},{"attribute_columns":["dbname","relname","schemaname"],"description":"Estimated number of live rows","metric_name":"ccp_stat_user_tables_n_live_tup","static_attributes":{"server":"localhost:5432"},"value_column":"n_live_tup"},{"attribute_columns":["dbname","relname","schemaname"],"data_type":"sum","description":"Number of rows deleted","metric_name":"ccp_stat_user_tables_n_tup_del","static_attributes":{"server":"localhost:5432"},"value_column":"n_tup_del"},{"attribute_columns":["dbname","relname","schemaname"],"data_type":"sum","description":"Number of rows HOT updated (i.e., with no separate index update required)","metric_name":"ccp_stat_user_tables_n_tup_hot_upd","static_attributes":{"server":"localhost:5432"},"value_column":"n_tup_hot_upd"},{"attribute_columns":["dbname","relname","schemaname"],"data_type":"sum","description":"Number of rows inserted","metric_name":"ccp_stat_user_tables_n_tup_ins","static_attributes":{"server":"localhost:5432"},"value_column":"n_tup_ins"},{"attribute_columns":["dbname","relname","schemaname"],"data_type":"sum","description":"Number of rows updated","metric_name":"ccp_stat_user_tables_n_tup_upd","static_attributes":{"server":"localhost:5432"},"value_column":"n_tup_upd"},{"attribute_columns":["dbname","relname","schemaname"],"data_type":"sum","description":"Number of sequential scans initiated on this table","metric_name":"ccp_stat_user_tables_seq_scan","static_attributes":{"server":"localhost:5432"},"value_column":"seq_scan"},{"attribute_columns":["dbname","relname","schemaname"],"data_type":"sum","description":"Number of live rows fetched by sequential scans","metric_name":"ccp_stat_user_tables_seq_tup_read","static_attributes":{"server":"localhost:5432"},"value_column":"seq_tup_read"},{"attribute_columns":["dbname","relname","schemaname"],"data_type":"sum","description":"Number of times this table has been manually vacuumed (not counting VACUUM FULL)","metric_name":"ccp_stat_user_tables_vacuum_count","static_attributes":{"server":"localhost:5432"},"value_column":"vacuum_count"}],"sql":"SELECT\n  current_database() as dbname\n  , p.schemaname\n  , p.relname\n  , p.seq_scan\n  , p.seq_tup_read\n  , COALESCE(p.idx_scan, 0) AS idx_scan\n  , COALESCE(p.idx_tup_fetch, 0) as idx_tup_fetch\n  , p.n_tup_ins\n  , p.n_tup_upd\n  , p.n_tup_del\n  , p.n_tup_hot_upd\n  , 0::bigint AS n_tup_newpage_upd\n  , p.n_live_tup\n  , p.n_dead_tup\n  , p.vacuum_count\n  , p.autovacuum_count\n  , p.analyze_count\n  , p.autoanalyze_count\nFROM pg_catalog.pg_stat_user_tables p;\n"},{"metrics":[{"attribute_columns":["database","slot_name","slot_type"],"description":"Active state of slot. 1 = true. 0 = false.","metric_name":"ccp_replication_slots_active","static_attributes":{"server":"localhost:5432"},"value_column":"active"},{"attribute_columns":["database","slot_name","slot_type"],"description":"The amount of WAL (in bytes) being retained for this slot","metric_name":"ccp_replication_slots_retained_bytes","static_attributes":{"server":"localhost:5432"},"value_column":"retained_bytes"},{"attribute_columns":["database","slot_name","slot_type"],"description":"True if this logical slot conflicted with recovery (and so is now invalidated). When this column is true, check invalidation_reason column for the conflict reason. Always NULL for physical slots.","metric_name":"ccp_replication_slots_conflicting","static_attributes":{"server":"localhost:5432"},"value_column":"conflicting"},{"attribute_columns":["database","slot_name","slot_type"],"description":"True if this is a logical slot enabled to be synced to the standbys so that logical replication can be resumed from the new primary after failover. Always false for physical slots.","metric_name":"ccp_replication_slots_failover","static_attributes":{"server":"localhost:5432"},"value_column":"failover"},{"attribute_columns":["database","slot_name","slot_type"],"description":"True if this is a logical slot that was synced from a primary server. On a hot standby, the slots with the synced column marked as true can neither be used for logical decoding nor dropped manually. The value of this column has no meaning on the primary server; the column value on the primary is default false for all slots but may (if leftover from a promoted standby) also be true.","metric_name":"ccp_replication_slots_synced","static_attributes":{"server":"localhost:5432"},"value_column":"synced"}],"sql":"SELECT\n    s.slot_name\n    , s.active::int\n    , COALESCE(pg_wal_lsn_diff(CASE WHEN pg_is_in_recovery() THEN pg_last_wal_replay_lsn() ELSE pg_current_wal_insert_lsn() END, s.restart_lsn), 0) AS retained_bytes\n    , COALESCE(s.database, '')\n    , s.slot_type\n    , 0 AS conflicting\n    , 0 AS failover\n    , 0 AS synced\nFROM pg_catalog.pg_replication_slots s;\n"}]
+[{"metrics":[{"attribute_columns":["dbname","relname","schemaname"],"data_type":"sum","description":"Number of times this table has been manually analyzed","metric_name":"ccp_stat_user_tables_analyze_count","static_attributes":{"server":"localhost:5432"},"value_column":"analyze_count"},{"attribute_columns":["dbname","relname","schemaname"],"data_type":"sum","description":"Number of times this table has been analyzed by the autovacuum daemon","metric_name":"ccp_stat_user_tables_autoanalyze_count","static_attributes":{"server":"localhost:5432"},"value_column":"autoanalyze_count"},{"attribute_columns":["dbname","relname","schemaname"],"data_type":"sum","description":"Number of times this table has been vacuumed by the autovacuum daemon","metric_name":"ccp_stat_user_tables_autovacuum_count","static_attributes":{"server":"localhost:5432"},"value_column":"autovacuum_count"},{"attribute_columns":["dbname","relname","schemaname"],"data_type":"sum","description":"Number of index scans initiated on this table","metric_name":"ccp_stat_user_tables_idx_scan","static_attributes":{"server":"localhost:5432"},"value_column":"idx_scan"},{"attribute_columns":["dbname","relname","schemaname"],"data_type":"sum","description":"Number of live rows fetched by index scans","metric_name":"ccp_stat_user_tables_idx_tup_fetch","static_attributes":{"server":"localhost:5432"},"value_column":"idx_tup_fetch"},{"attribute_columns":["dbname","relname","schemaname"],"description":"Estimated number of dead rows","metric_name":"ccp_stat_user_tables_n_dead_tup","static_attributes":{"server":"localhost:5432"},"value_column":"n_dead_tup"},{"attribute_columns":["dbname","relname","schemaname"],"description":"Estimated number of live rows","metric_name":"ccp_stat_user_tables_n_live_tup","static_attributes":{"server":"localhost:5432"},"value_column":"n_live_tup"},{"attribute_columns":["dbname","relname","schemaname"],"data_type":"sum","description":"Number of rows deleted","metric_name":"ccp_stat_user_tables_n_tup_del","static_attributes":{"server":"localhost:5432"},"value_column":"n_tup_del"},{"attribute_columns":["dbname","relname","schemaname"],"data_type":"sum","description":"Number of rows HOT updated (i.e., with no separate index update required)","metric_name":"ccp_stat_user_tables_n_tup_hot_upd","static_attributes":{"server":"localhost:5432"},"value_column":"n_tup_hot_upd"},{"attribute_columns":["dbname","relname","schemaname"],"data_type":"sum","description":"Number of rows inserted","metric_name":"ccp_stat_user_tables_n_tup_ins","static_attributes":{"server":"localhost:5432"},"value_column":"n_tup_ins"},{"attribute_columns":["dbname","relname","schemaname"],"data_type":"sum","description":"Number of rows updated","metric_name":"ccp_stat_user_tables_n_tup_upd","static_attributes":{"server":"localhost:5432"},"value_column":"n_tup_upd"},{"attribute_columns":["dbname","relname","schemaname"],"data_type":"sum","description":"Number of sequential scans initiated on this table","metric_name":"ccp_stat_user_tables_seq_scan","static_attributes":{"server":"localhost:5432"},"value_column":"seq_scan"},{"attribute_columns":["dbname","relname","schemaname"],"data_type":"sum","description":"Number of live rows fetched by sequential scans","metric_name":"ccp_stat_user_tables_seq_tup_read","static_attributes":{"server":"localhost:5432"},"value_column":"seq_tup_read"},{"attribute_columns":["dbname","relname","schemaname"],"data_type":"sum","description":"Number of times this table has been manually vacuumed (not counting VACUUM FULL)","metric_name":"ccp_stat_user_tables_vacuum_count","static_attributes":{"server":"localhost:5432"},"value_column":"vacuum_count"}],"sql":"SELECT\n  current_database() as dbname\n  , p.schemaname\n  , p.relname\n  , p.seq_scan\n  , p.seq_tup_read\n  , COALESCE(p.idx_scan, 0) AS idx_scan\n  , COALESCE(p.idx_tup_fetch, 0) as idx_tup_fetch\n  , p.n_tup_ins\n  , p.n_tup_upd\n  , p.n_tup_del\n  , p.n_tup_hot_upd\n  , 0::bigint AS n_tup_newpage_upd\n  , p.n_live_tup\n  , p.n_dead_tup\n  , p.vacuum_count\n  , p.autovacuum_count\n  , p.analyze_count\n  , p.autoanalyze_count\nFROM pg_catalog.pg_stat_user_tables p;\n"}]
diff --git a/internal/collector/generated/lt_pg17_metrics.json b/internal/collector/generated/lt_pg17_fast_metrics.json
similarity index 100%
rename from internal/collector/generated/lt_pg17_metrics.json
rename to internal/collector/generated/lt_pg17_fast_metrics.json
diff --git a/internal/collector/generated/postgres_5m_metrics.json b/internal/collector/generated/postgres_5m_metrics.json
index 371a7fa182..8821cf6ab1 100644
--- a/internal/collector/generated/postgres_5m_metrics.json
+++ b/internal/collector/generated/postgres_5m_metrics.json
@@ -1 +1 @@
-[{"metrics":[{"attribute_columns":["dbname"],"description":"Database size in bytes","metric_name":"ccp_database_size_bytes","static_attributes":{"server":"localhost:5432"},"value_column":"bytes"}],"sql":"SELECT datname as dbname , pg_database_size(datname) as bytes FROM pg_catalog.pg_database WHERE datistemplate = false;\n"},{"metrics":[{"description":"Count of sequences that have reached greater than or equal to 75% of their max available numbers.\nFunction monitor.sequence_status() can provide more details if run directly on system.\n","metric_name":"ccp_sequence_exhaustion_count","static_attributes":{"server":"localhost:5432"},"value_column":"count"}],"sql":"SELECT count(*) AS count FROM (\n     SELECT CEIL((s.max_value-min_value::NUMERIC+1)/s.increment_by::NUMERIC) AS slots\n        , CEIL((COALESCE(s.last_value,s.min_value)-s.min_value::NUMERIC+1)/s.increment_by::NUMERIC) AS used\n    FROM pg_catalog.pg_sequences s\n) x WHERE (ROUND(used/slots*100)::int) \u003e 75;\n"},{"metrics":[{"attribute_columns":["dbname"],"description":"Number of times disk blocks were found already in the buffer cache, so that a read was not necessary","metric_name":"ccp_stat_database_blks_hit","static_attributes":{"server":"localhost:5432"},"value_column":"blks_hit"},{"attribute_columns":["dbname"],"description":"Number of disk blocks read in this database","metric_name":"ccp_stat_database_blks_read","static_attributes":{"server":"localhost:5432"},"value_column":"blks_read"},{"attribute_columns":["dbname"],"description":"Number of queries canceled due to conflicts with recovery in this database","metric_name":"ccp_stat_database_conflicts","static_attributes":{"server":"localhost:5432"},"value_column":"conflicts"},{"attribute_columns":["dbname"],"description":"Number of deadlocks detected in this database","metric_name":"ccp_stat_database_deadlocks","static_attributes":{"server":"localhost:5432"},"value_column":"deadlocks"},{"attribute_columns":["dbname"],"description":"Total amount of data written to temporary files by queries in this database","metric_name":"ccp_stat_database_temp_bytes","static_attributes":{"server":"localhost:5432"},"value_column":"temp_bytes"},{"attribute_columns":["dbname"],"description":"Number of rows deleted by queries in this database","metric_name":"ccp_stat_database_temp_files","static_attributes":{"server":"localhost:5432"},"value_column":"temp_files"},{"attribute_columns":["dbname"],"description":"Number of rows deleted by queries in this database","metric_name":"ccp_stat_database_tup_deleted","static_attributes":{"server":"localhost:5432"},"value_column":"tup_deleted"},{"attribute_columns":["dbname"],"description":"Number of rows fetched by queries in this database","metric_name":"ccp_stat_database_tup_fetched","static_attributes":{"server":"localhost:5432"},"value_column":"tup_fetched"},{"attribute_columns":["dbname"],"description":"Number of rows inserted by queries in this database","metric_name":"ccp_stat_database_tup_inserted","static_attributes":{"server":"localhost:5432"},"value_column":"tup_inserted"},{"attribute_columns":["dbname"],"description":"Number of rows returned by queries in this database","metric_name":"ccp_stat_database_tup_returned","static_attributes":{"server":"localhost:5432"},"value_column":"tup_returned"},{"attribute_columns":["dbname"],"description":"Number of rows updated by queries in this database","metric_name":"ccp_stat_database_tup_updated","static_attributes":{"server":"localhost:5432"},"value_column":"tup_updated"},{"attribute_columns":["dbname"],"description":"Number of transactions in this database that have been committed","metric_name":"ccp_stat_database_xact_commit","static_attributes":{"server":"localhost:5432"},"value_column":"xact_commit"},{"attribute_columns":["dbname"],"description":"Number of transactions in this database that have been rolled back","metric_name":"ccp_stat_database_xact_rollback","static_attributes":{"server":"localhost:5432"},"value_column":"xact_rollback"}],"sql":"SELECT s.datname AS dbname , s.xact_commit , s.xact_rollback , s.blks_read , s.blks_hit , s.tup_returned , s.tup_fetched , s.tup_inserted , s.tup_updated , s.tup_deleted , s.conflicts , s.temp_files , s.temp_bytes , s.deadlocks FROM pg_catalog.pg_stat_database s JOIN pg_catalog.pg_database d ON d.datname = s.datname WHERE d.datistemplate = false;\n"},{"metrics":[{"description":"Value of checksum monitoring status for pg_catalog.pg_hba_file_rules (pg_hba.conf).\n0 = valid config. 1 = settings changed. \nSettings history is available for review in the table `monitor.pg_hba_checksum`.\nTo reset current config to valid after alert, run monitor.pg_hba_checksum_set_valid(). Note this will clear the history table.\n","metric_name":"ccp_pg_hba_checksum","static_attributes":{"server":"localhost:5432"},"value_column":"status"}],"sql":"SELECT monitor.pg_hba_checksum() AS status;"}]
+[{"metrics":[{"attribute_columns":["dbname"],"description":"Database size in bytes","metric_name":"ccp_database_size_bytes","static_attributes":{"server":"localhost:5432"},"value_column":"bytes"}],"sql":"SELECT datname as dbname , pg_database_size(datname) as bytes FROM pg_catalog.pg_database WHERE datistemplate = false;\n"},{"metrics":[{"description":"Count of sequences that have reached greater than or equal to 75% of their max available numbers.\nFunction monitor.sequence_status() can provide more details if run directly on system.\n","metric_name":"ccp_sequence_exhaustion_count","static_attributes":{"server":"localhost:5432"},"value_column":"count"}],"sql":"SELECT count(*) AS count FROM (\n     SELECT CEIL((s.max_value-min_value::NUMERIC+1)/s.increment_by::NUMERIC) AS slots\n        , CEIL((COALESCE(s.last_value,s.min_value)-s.min_value::NUMERIC+1)/s.increment_by::NUMERIC) AS used\n    FROM pg_catalog.pg_sequences s\n) x WHERE (ROUND(used/slots*100)::int) \u003e 75;\n"}]
diff --git a/internal/collector/generated/postgres_5s_metrics.json b/internal/collector/generated/postgres_5s_metrics.json
index 484c99dfa0..978f89d305 100644
--- a/internal/collector/generated/postgres_5s_metrics.json
+++ b/internal/collector/generated/postgres_5s_metrics.json
@@ -1 +1 @@
-[{"metrics":[{"attribute_columns":["application_name","datname","state","usename"],"description":"number of connections in this state","metric_name":"ccp_pg_stat_activity_count","static_attributes":{"server":"localhost:5432"},"value_column":"count"}],"sql":"SELECT\n    pg_database.datname,\n    tmp.state,\n    COALESCE(tmp2.usename, '') as usename,\n    COALESCE(tmp2.application_name, '') as application_name,\n    COALESCE(count,0) as count,\n    COALESCE(max_tx_duration,0) as max_tx_duration\nFROM\n    (\n      VALUES ('active'),\n             ('idle'),\n             ('idle in transaction'),\n             ('idle in transaction (aborted)'),\n             ('fastpath function call'),\n             ('disabled')\n    ) AS tmp(state) CROSS JOIN pg_database\nLEFT JOIN (\n    SELECT\n        datname,\n        state,\n        usename,\n        application_name,\n        count(*) AS count,\n        MAX(EXTRACT(EPOCH FROM now() - xact_start))::float AS max_tx_duration\n    FROM pg_stat_activity GROUP BY datname,state,usename,application_name) AS tmp2\n    ON tmp.state = tmp2.state AND pg_database.datname = tmp2.datname;\n"},{"metrics":[{"description":"Seconds since the last successful archive operation","metric_name":"ccp_archive_command_status_seconds_since_last_archive","static_attributes":{"server":"localhost:5432"},"value_column":"seconds_since_last_archive","value_type":"double"}],"sql":"SELECT COALESCE(EXTRACT(epoch from (CURRENT_TIMESTAMP - last_archived_time)), 0) AS seconds_since_last_archive FROM pg_catalog.pg_stat_archiver;\n"},{"metrics":[{"description":"Number of WAL files that have been successfully archived","metric_name":"ccp_archive_command_status_archived_count","static_attributes":{"server":"localhost:5432"},"value_column":"archived_count"}],"sql":"SELECT archived_count FROM pg_catalog.pg_stat_archiver\n"},{"metrics":[{"description":"Number of failed attempts for archiving WAL files","metric_name":"ccp_archive_command_status_failed_count","static_attributes":{"server":"localhost:5432"},"value_column":"failed_count"}],"sql":"SELECT failed_count FROM pg_catalog.pg_stat_archiver\n"},{"metrics":[{"description":"Seconds since the last recorded failure of the archive_command","metric_name":"ccp_archive_command_status_seconds_since_last_fail","static_attributes":{"server":"localhost:5432"},"value_column":"seconds_since_last_fail"}],"sql":"SELECT CASE\n    WHEN EXTRACT(epoch from (last_failed_time - last_archived_time)) IS NULL THEN 0\n    WHEN EXTRACT(epoch from (last_failed_time - last_archived_time)) \u003c 0 THEN 0\n    ELSE EXTRACT(epoch from (last_failed_time - last_archived_time))\n    END AS seconds_since_last_fail\nFROM pg_catalog.pg_stat_archiver\n"},{"metrics":[{"description":"Total non-idle connections","metric_name":"ccp_connection_stats_active","static_attributes":{"server":"localhost:5432"},"value_column":"active"},{"description":"Total idle connections","metric_name":"ccp_connection_stats_idle","static_attributes":{"server":"localhost:5432"},"value_column":"idle"},{"description":"Total idle in transaction connections","metric_name":"ccp_connection_stats_idle_in_txn","static_attributes":{"server":"localhost:5432"},"value_column":"idle_in_txn"},{"description":"Value of max_connections for the monitored database","metric_name":"ccp_connection_stats_max_blocked_query_time","static_attributes":{"server":"localhost:5432"},"value_column":"max_blocked_query_time","value_type":"double"},{"description":"Value of max_connections for the monitored database","metric_name":"ccp_connection_stats_max_connections","static_attributes":{"server":"localhost:5432"},"value_column":"max_connections"},{"description":"Length of time in seconds of the longest idle in transaction session","metric_name":"ccp_connection_stats_max_idle_in_txn_time","static_attributes":{"server":"localhost:5432"},"value_column":"max_idle_in_txn_time","value_type":"double"},{"description":"Length of time in seconds of the longest running query","metric_name":"ccp_connection_stats_max_query_time","static_attributes":{"server":"localhost:5432"},"value_column":"max_query_time","value_type":"double"},{"description":"Total idle and non-idle connections","metric_name":"ccp_connection_stats_total","static_attributes":{"server":"localhost:5432"},"value_column":"total"}],"sql":"SELECT ((total - idle) - idle_in_txn) as active\n    , total\n    , idle\n    , idle_in_txn\n    , (SELECT COALESCE(EXTRACT(epoch FROM (MAX(clock_timestamp() - state_change))),0) FROM pg_catalog.pg_stat_activity WHERE state = 'idle in transaction') AS max_idle_in_txn_time\n    , (SELECT COALESCE(EXTRACT(epoch FROM (MAX(clock_timestamp() - query_start))),0) FROM pg_catalog.pg_stat_activity WHERE backend_type = 'client backend' AND state \u003c\u003e 'idle' ) AS max_query_time\n    , (SELECT COALESCE(EXTRACT(epoch FROM (MAX(clock_timestamp() - query_start))),0) FROM pg_catalog.pg_stat_activity WHERE backend_type = 'client backend' AND wait_event_type = 'Lock' ) AS max_blocked_query_time\n    , max_connections\n    FROM (\n            SELECT COUNT(*) as total\n                    , COALESCE(SUM(CASE WHEN state = 'idle' THEN 1 ELSE 0 END),0) AS idle\n                    , COALESCE(SUM(CASE WHEN state = 'idle in transaction' THEN 1 ELSE 0 END),0) AS idle_in_txn FROM pg_catalog.pg_stat_activity) x\n    JOIN (SELECT setting::float AS max_connections FROM pg_settings WHERE name = 'max_connections') xx ON (true);\n"},{"metrics":[{"attribute_columns":["dbname"],"description":"Total number of checksum failures on this database","metric_name":"ccp_data_checksum_failure_count","static_attributes":{"server":"localhost:5432"},"value_column":"count"},{"attribute_columns":["dbname"],"description":"Time interval in seconds since the last checksum failure was encountered","metric_name":"ccp_data_checksum_failure_time_since_last_failure_seconds","static_attributes":{"server":"localhost:5432"},"value_column":"time_since_last_failure_seconds","value_type":"double"}],"sql":"SELECT datname AS dbname , checksum_failures AS count , coalesce(extract(epoch from (clock_timestamp() - checksum_last_failure)), 0) AS time_since_last_failure_seconds FROM pg_catalog.pg_stat_database WHERE pg_stat_database.datname IS NOT NULL;\n"},{"metrics":[{"attribute_columns":["dbname","mode"],"description":"Number of locks per mode type","metric_name":"ccp_locks_count","static_attributes":{"server":"localhost:5432"},"value_column":"count"}],"sql":"SELECT pg_database.datname as dbname , tmp.mode , COALESCE(count,0) as count FROM (\n  VALUES ('accesssharelock'),\n         ('rowsharelock'),\n         ('rowexclusivelock'),\n         ('shareupdateexclusivelock'),\n         ('sharelock'),\n         ('sharerowexclusivelock'),\n         ('exclusivelock'),\n         ('accessexclusivelock')\n) AS tmp(mode) CROSS JOIN pg_catalog.pg_database LEFT JOIN\n    (SELECT database, lower(mode) AS mode,count(*) AS count\n    FROM pg_catalog.pg_locks WHERE database IS NOT NULL\n    GROUP BY database, lower(mode)\n) AS tmp2 ON tmp.mode=tmp2.mode and pg_database.oid = tmp2.database;\n"},{"metrics":[{"description":"CPU limit value in milli cores","metric_name":"ccp_nodemx_cpu_limit","static_attributes":{"server":"localhost:5432"},"value_column":"limit"},{"description":"CPU request value in milli cores","metric_name":"ccp_nodemx_cpu_request","static_attributes":{"server":"localhost:5432"},"value_column":"request"}],"sql":"SELECT monitor.kdapi_scalar_bigint('cpu_request') AS request , monitor.kdapi_scalar_bigint('cpu_limit') AS limit\n"},{"metrics":[{"description":"CPU usage in nanoseconds","metric_name":"ccp_nodemx_cpuacct_usage","static_attributes":{"server":"localhost:5432"},"value_column":"usage","value_type":"double"},{"description":"CPU usage snapshot timestamp","metric_name":"ccp_nodemx_cpuacct_usage_ts","static_attributes":{"server":"localhost:5432"},"value_column":"usage_ts","value_type":"double"}],"sql":"SELECT CASE WHEN monitor.cgroup_mode() = 'legacy'\n  THEN monitor.cgroup_scalar_bigint('cpuacct.usage')\n  ELSE (SELECT val FROM monitor.cgroup_setof_kv('cpu.stat') where key = 'usage_usec') * 1000\n  END AS usage,\n  extract(epoch from clock_timestamp()) AS usage_ts;\n"},{"metrics":[{"description":"The total available run-time within a period (in microseconds)","metric_name":"ccp_nodemx_cpucfs_period_us","static_attributes":{"server":"localhost:5432"},"value_column":"period_us"},{"description":"The length of a period (in microseconds)","metric_name":"ccp_nodemx_cpucfs_quota_us","static_attributes":{"server":"localhost:5432"},"value_column":"quota_us","value_type":"double"}],"sql":"SELECT\n  CASE\n  WHEN monitor.cgroup_mode() = 'legacy' THEN\n    monitor.cgroup_scalar_bigint('cpu.cfs_period_us')\n  ELSE\n    (monitor.cgroup_array_bigint('cpu.max'))[2]\n  END AS period_us,\n  CASE\n  WHEN monitor.cgroup_mode() = 'legacy' THEN\n    GREATEST(monitor.cgroup_scalar_bigint('cpu.cfs_quota_us'), 0)\n  ELSE\n    GREATEST((monitor.cgroup_array_bigint('cpu.max'))[1], 0)\n  END AS quota_us;\n"},{"metrics":[{"description":"Number of periods that any thread was runnable","metric_name":"ccp_nodemx_cpustat_nr_periods","static_attributes":{"server":"localhost:5432"},"value_column":"nr_periods","value_type":"double"},{"description":"Number of runnable periods in which the application used its entire quota and was throttled","metric_name":"ccp_nodemx_cpustat_nr_throttled","static_attributes":{"server":"localhost:5432"},"value_column":"nr_throttled"},{"description":"CPU stat snapshot timestamp","metric_name":"ccp_nodemx_cpustat_snap_ts","static_attributes":{"server":"localhost:5432"},"value_column":"snap_ts","value_type":"double"},{"description":"Sum total amount of time individual threads within the monitor.cgroup were throttled","metric_name":"ccp_nodemx_cpustat_throttled_time","static_attributes":{"server":"localhost:5432"},"value_column":"throttled_time","value_type":"double"}],"sql":"WITH d(key, val) AS (select key, val from monitor.cgroup_setof_kv('cpu.stat')) SELECT\n (SELECT val FROM d WHERE key='nr_periods') AS nr_periods,\n (SELECT val FROM d WHERE key='nr_throttled') AS nr_throttled,\n (SELECT val FROM d WHERE key='throttled_usec') AS throttled_time,\n extract(epoch from clock_timestamp()) as snap_ts;\n"},{"metrics":[{"attribute_columns":["fs_type","mount_point"],"description":"Available size in bytes","metric_name":"ccp_nodemx_data_disk_available_bytes","static_attributes":{"server":"localhost:5432"},"value_column":"available_bytes","value_type":"double"},{"attribute_columns":["fs_type","mount_point"],"description":"Available file nodes","metric_name":"ccp_nodemx_data_disk_free_file_nodes","static_attributes":{"server":"localhost:5432"},"value_column":"free_file_nodes"},{"attribute_columns":["fs_type","mount_point"],"description":"Size in bytes","metric_name":"ccp_nodemx_data_disk_total_bytes","static_attributes":{"server":"localhost:5432"},"value_column":"total_bytes"},{"attribute_columns":["fs_type","mount_point"],"description":"Total file nodes","metric_name":"ccp_nodemx_data_disk_total_file_nodes","static_attributes":{"server":"localhost:5432"},"value_column":"total_file_nodes"}],"sql":"SELECT mount_point,fs_type,total_bytes,available_bytes,total_file_nodes,free_file_nodes\n          FROM monitor.proc_mountinfo() m\n          JOIN monitor.fsinfo(m.mount_point) f USING (major_number, minor_number)\n          WHERE m.mount_point IN ('/pgdata', '/pgwal') OR\n                m.mount_point like '/tablespaces/%'\n"},{"metrics":[{"attribute_columns":["mount_point"],"description":"Total sectors read","metric_name":"ccp_nodemx_disk_activity_sectors_read","static_attributes":{"server":"localhost:5432"},"value_column":"sectors_read"},{"attribute_columns":["mount_point"],"description":"Total sectors written","metric_name":"ccp_nodemx_disk_activity_sectors_written","static_attributes":{"server":"localhost:5432"},"value_column":"sectors_written"}],"sql":"SELECT mount_point,sectors_read,sectors_written\n          FROM monitor.proc_mountinfo() m\n          JOIN monitor.proc_diskstats() d USING (major_number, minor_number)\n          WHERE m.mount_point IN ('/pgdata', '/pgwal') OR\n                m.mount_point like '/tablespaces/%';\n"},{"metrics":[{"description":"Total bytes of anonymous and swap cache memory on active LRU list","metric_name":"ccp_nodemx_mem_active_anon","static_attributes":{"server":"localhost:5432"},"value_column":"active_anon","value_type":"double"},{"description":"Total bytes of file-backed memory on active LRU list","metric_name":"ccp_nodemx_mem_active_file","static_attributes":{"server":"localhost:5432"},"value_column":"active_file","value_type":"double"},{"description":"Total bytes of page cache memory","metric_name":"ccp_nodemx_mem_cache","static_attributes":{"server":"localhost:5432"},"value_column":"cache","value_type":"double"},{"description":"Total bytes that are waiting to get written back to the disk","metric_name":"ccp_nodemx_mem_dirty","static_attributes":{"server":"localhost:5432"},"value_column":"dirty"},{"description":"Total bytes of anonymous and swap cache memory on inactive LRU list","metric_name":"ccp_nodemx_mem_inactive_anon","static_attributes":{"server":"localhost:5432"},"value_column":"inactive_anon","value_type":"double"},{"description":"Total bytes of file-backed memory on inactive LRU list","metric_name":"ccp_nodemx_mem_inactive_file","static_attributes":{"server":"localhost:5432"},"value_column":"inactive_file","value_type":"double"},{"description":"Unknown metric from ccp_nodemx_mem","metric_name":"ccp_nodemx_mem_kmem_usage_in_byte","static_attributes":{"server":"localhost:5432"},"value_column":"kmem_usage_in_byte"},{"description":"Memory limit value in bytes","metric_name":"ccp_nodemx_mem_limit","static_attributes":{"server":"localhost:5432"},"value_column":"limit"},{"description":"Total bytes of mapped file (includes tmpfs/shmem)","metric_name":"ccp_nodemx_mem_mapped_file","static_attributes":{"server":"localhost:5432"},"value_column":"mapped_file"},{"description":"Memory request value in bytes","metric_name":"ccp_nodemx_mem_request","static_attributes":{"server":"localhost:5432"},"value_column":"request"},{"description":"Total bytes of anonymous and swap cache memory","metric_name":"ccp_nodemx_mem_rss","static_attributes":{"server":"localhost:5432"},"value_column":"rss","value_type":"double"},{"description":"Total bytes of shared memory","metric_name":"ccp_nodemx_mem_shmem","static_attributes":{"server":"localhost:5432"},"value_column":"shmem","value_type":"double"},{"description":"Total usage in bytes","metric_name":"ccp_nodemx_mem_usage_in_bytes","static_attributes":{"server":"localhost:5432"},"value_column":"usage_in_bytes"}],"sql":"WITH d(key, val) as (SELECT key, val FROM monitor.cgroup_setof_kv('memory.stat')) SELECT\n  monitor.kdapi_scalar_bigint('mem_request') AS request,\n  CASE\n    WHEN monitor.cgroup_mode() = 'legacy' THEN\n        (CASE WHEN monitor.cgroup_scalar_bigint('memory.limit_in_bytes') = 9223372036854771712 THEN 0 ELSE monitor.cgroup_scalar_bigint('memory.limit_in_bytes') END)\n    ELSE\n        (CASE WHEN monitor.cgroup_scalar_bigint('memory.max') = 9223372036854775807 THEN 0 ELSE monitor.cgroup_scalar_bigint('memory.max') END)\n  END AS limit,\n  CASE\n    WHEN monitor.cgroup_mode() = 'legacy'\n    THEN (SELECT val FROM d WHERE key='cache')\n    ELSE 0\n  END as cache,\n  CASE\n    WHEN monitor.cgroup_mode() = 'legacy'\n    THEN (SELECT val FROM d WHERE key='rss')\n    ELSE 0\n  END as RSS,\n  (SELECT val FROM d WHERE key='shmem') as shmem,\n  CASE\n    WHEN monitor.cgroup_mode() = 'legacy'\n    THEN (SELECT val FROM d WHERE key='mapped_file')\n    ELSE 0\n  END as mapped_file,\n  CASE\n    WHEN monitor.cgroup_mode() = 'legacy'\n    THEN (SELECT val FROM d WHERE key='dirty')\n    ELSE (SELECT val FROM d WHERE key='file_dirty')\n  END as dirty,\n  (SELECT val FROM d WHERE key='active_anon') as active_anon,\n  (SELECT val FROM d WHERE key='inactive_anon') as inactive_anon,\n  (SELECT val FROM d WHERE key='active_file') as active_file,\n  (SELECT val FROM d WHERE key='inactive_file') as inactive_file,\n  CASE\n    WHEN monitor.cgroup_mode() = 'legacy'\n    THEN monitor.cgroup_scalar_bigint('memory.usage_in_bytes')\n    ELSE monitor.cgroup_scalar_bigint('memory.current')\n  END as usage_in_bytes,\n  CASE\n    WHEN monitor.cgroup_mode() = 'legacy'\n    THEN monitor.cgroup_scalar_bigint('memory.kmem.usage_in_bytes')\n    ELSE 0\n  END as kmem_usage_in_byte;\n"},{"metrics":[{"attribute_columns":["interface"],"description":"Number of bytes received","metric_name":"ccp_nodemx_network_rx_bytes","static_attributes":{"server":"localhost:5432"},"value_column":"rx_bytes"},{"attribute_columns":["interface"],"description":"Number of packets received","metric_name":"ccp_nodemx_network_rx_packets","static_attributes":{"server":"localhost:5432"},"value_column":"rx_packets"},{"attribute_columns":["interface"],"description":"Number of bytes transmitted","metric_name":"ccp_nodemx_network_tx_bytes","static_attributes":{"server":"localhost:5432"},"value_column":"tx_bytes"},{"attribute_columns":["interface"],"description":"Number of packets transmitted","metric_name":"ccp_nodemx_network_tx_packets","static_attributes":{"server":"localhost:5432"},"value_column":"tx_packets"}],"sql":"SELECT interface\n  ,tx_bytes\n  ,tx_packets\n  ,rx_bytes\n  ,rx_packets from monitor.proc_network_stats()\n"},{"metrics":[{"description":"Total number of database processes","metric_name":"ccp_nodemx_process_count","static_attributes":{"server":"localhost:5432"},"value_column":"count"}],"sql":"SELECT monitor.cgroup_process_count() as count;\n"},{"metrics":[{"description":"Epoch time when stats were reset","metric_name":"ccp_pg_stat_statements_reset_time","static_attributes":{"server":"localhost:5432"},"value_column":"time"}],"sql":"SELECT monitor.pg_stat_statements_reset_info(-1) as time;\n"},{"metrics":[{"attribute_columns":["dbname","query","queryid","role"],"description":"Average query runtime in milliseconds","metric_name":"ccp_pg_stat_statements_top_mean_exec_time_ms","static_attributes":{"server":"localhost:5432"},"value_column":"top_mean_exec_time_ms","value_type":"double"}],"sql":"WITH monitor AS (\n  SELECT\n    pg_get_userbyid(s.userid) AS role\n    , d.datname AS dbname\n    , s.queryid AS queryid\n    , btrim(replace(left(s.query, 40), '\\n', '')) AS query\n    , s.calls\n    , s.total_exec_time AS total_exec_time\n    , s.max_exec_time AS max_exec_time\n    , s.mean_exec_time AS mean_exec_time\n    , s.rows\n    , s.wal_records AS records\n    , s.wal_fpi AS fpi\n    , s.wal_bytes AS bytes\n  FROM public.pg_stat_statements s\n  JOIN pg_catalog.pg_database d ON d.oid = s.dbid\n) SELECT role\n  , dbname\n  , queryid\n  , query\n  , max(monitor.mean_exec_time) AS top_mean_exec_time_ms\nFROM monitor GROUP BY 1,2,3,4 ORDER BY 5 DESC LIMIT 20;\n"},{"metrics":[{"attribute_columns":["dbname","role"],"description":"Total number of queries run per user/database","metric_name":"ccp_pg_stat_statements_total_calls_count","static_attributes":{"server":"localhost:5432"},"value_column":"calls_count","value_type":"double"},{"attribute_columns":["dbname","role"],"description":"Total runtime of all queries per user/database","metric_name":"ccp_pg_stat_statements_total_exec_time_ms","static_attributes":{"server":"localhost:5432"},"value_column":"exec_time_ms","value_type":"double"},{"attribute_columns":["dbname","role"],"description":"Total runtime of all queries per user/database","metric_name":"ccp_pg_stat_statements_total_mean_exec_time_ms","static_attributes":{"server":"localhost:5432"},"value_column":"mean_exec_time_ms","value_type":"double"},{"attribute_columns":["dbname","role"],"description":"Total rows returned from all queries per user/database","metric_name":"ccp_pg_stat_statements_total_row_count","static_attributes":{"server":"localhost:5432"},"value_column":"row_count","value_type":"double"}],"sql":"WITH monitor AS (\n  SELECT\n    pg_get_userbyid(s.userid) AS role\n    , d.datname AS dbname\n    , s.calls\n    , s.total_exec_time\n    , s.mean_exec_time\n    , s.rows\n  FROM public.pg_stat_statements s\n  JOIN pg_catalog.pg_database d ON d.oid = s.dbid\n) SELECT role\n  , dbname\n  , sum(calls) AS calls_count\n  , sum(total_exec_time) AS exec_time_ms\n  , avg(mean_exec_time) AS mean_exec_time_ms\n  , sum(rows) AS row_count\nFROM monitor GROUP BY 1,2;\n"},{"metrics":[{"description":"The current version of PostgreSQL that this exporter is running on as a 6 digit integer (######).","metric_name":"ccp_postgresql_version_current","static_attributes":{"server":"localhost:5432"},"value_column":"current"}],"sql":"SELECT current_setting('server_version_num')::int AS current;\n"},{"metrics":[{"description":"Time interval in seconds since PostgreSQL database was last restarted.","metric_name":"ccp_postmaster_uptime_seconds","static_attributes":{"server":"localhost:5432"},"value_column":"seconds","value_type":"double"}],"sql":"SELECT extract(epoch from (clock_timestamp() - pg_postmaster_start_time() )) AS seconds;\n"},{"metrics":[{"description":"Time interval in seconds since PostgreSQL database was last restarted.","metric_name":"ccp_replication_lag_size_bytes","static_attributes":{"server":"localhost:5432"},"value_column":"bytes","value_type":"double"}],"sql":"SELECT * FROM get_replication_lag();\n"},{"metrics":[{"description":"Return value of 1 means database is in recovery. Otherwise 2 it is a primary","metric_name":"ccp_is_in_recovery_status","static_attributes":{"server":"localhost:5432"},"value_column":"status","value_type":"double"},{"attribute_columns":["role"],"description":"Length of time since the last WAL file was received and replayed on replica.\nAlways increases, possibly causing false positives if the primary stops writing.\nMonitors for replicas that stop receiving WAL all together.\n","metric_name":"ccp_replication_lag_received_time","static_attributes":{"server":"localhost:5432"},"value_column":"received_time","value_type":"double"},{"attribute_columns":["role"],"description":"Length of time since the last transaction was replayed on replica.\nReturns zero if last WAL received equals last WAL replayed. Avoids\nfalse positives when primary stops writing. Monitors for replicas that\ncannot keep up with primary WAL generation.\n","metric_name":"ccp_replication_lag_replay_time","static_attributes":{"server":"localhost:5432"},"value_column":"replay_time","value_type":"double"}],"sql":"SELECT\n   COALESCE(\n      CASE\n         WHEN (pg_last_wal_receive_lsn() = pg_last_wal_replay_lsn()) OR (pg_is_in_recovery() = false) THEN 0\n         ELSE EXTRACT (EPOCH FROM clock_timestamp() - pg_last_xact_replay_timestamp())::INTEGER\n      END,\n      0\n   ) AS replay_time,\n   COALESCE(\n      CASE\n         WHEN pg_is_in_recovery() = false THEN 0\n         ELSE EXTRACT (EPOCH FROM clock_timestamp() - pg_last_xact_replay_timestamp())::INTEGER\n      END,\n      0\n   ) AS received_time,\n   CASE\n      WHEN pg_is_in_recovery() = true THEN 'replica'\n      ELSE 'primary'\n   END AS role,\n   CASE\n      WHEN pg_is_in_recovery() = true THEN 1\n      ELSE 2\n   END AS status;\n"},{"metrics":[{"description":"Number of settings from pg_settings catalog in a pending_restart state","metric_name":"ccp_settings_pending_restart_count","static_attributes":{"server":"localhost:5432"},"value_column":"count"}],"sql":"SELECT count(*) AS count FROM pg_catalog.pg_settings WHERE pending_restart = true;\n"},{"metrics":[{"description":"Number of buffers allocated","metric_name":"ccp_stat_bgwriter_buffers_alloc","static_attributes":{"server":"localhost:5432"},"value_column":"buffers_alloc"},{"data_type":"sum","description":"Number of buffers written by the background writer","metric_name":"ccp_stat_bgwriter_buffers_clean","static_attributes":{"server":"localhost:5432"},"value_column":"buffers_clean"},{"description":"Number of times the background writer stopped a cleaning scan because it had written too many buffers","metric_name":"ccp_stat_bgwriter_maxwritten_clean","static_attributes":{"server":"localhost:5432"},"value_column":"maxwritten_clean"}],"sql":"SELECT\n    buffers_clean\n    , maxwritten_clean\n    , buffers_alloc\nFROM pg_catalog.pg_stat_bgwriter;\n"},{"metrics":[{"description":"Oldest current transaction ID in cluster","metric_name":"ccp_transaction_wraparound_oldest_current_xid","static_attributes":{"server":"localhost:5432"},"value_column":"oldest_current_xid"},{"description":"Percentage towards emergency autovacuum process starting","metric_name":"ccp_transaction_wraparound_percent_towards_emergency_autovac","static_attributes":{"server":"localhost:5432"},"value_column":"percent_towards_emergency_autovac"},{"description":"Percentage towards transaction ID wraparound","metric_name":"ccp_transaction_wraparound_percent_towards_wraparound","static_attributes":{"server":"localhost:5432"},"value_column":"percent_towards_wraparound"}],"sql":"WITH max_age AS (\n    SELECT 2000000000 as max_old_xid\n    , setting AS autovacuum_freeze_max_age\n    FROM pg_catalog.pg_settings\n    WHERE name = 'autovacuum_freeze_max_age')\n, per_database_stats AS (\n    SELECT datname\n    , m.max_old_xid::int\n    , m.autovacuum_freeze_max_age::int\n    , age(d.datfrozenxid) AS oldest_current_xid\n    FROM pg_catalog.pg_database d\n    JOIN max_age m ON (true)\n    WHERE d.datallowconn)\nSELECT max(oldest_current_xid) AS oldest_current_xid , max(ROUND(100*(oldest_current_xid/max_old_xid::float))) AS percent_towards_wraparound , max(ROUND(100*(oldest_current_xid/autovacuum_freeze_max_age::float))) AS percent_towards_emergency_autovac FROM per_database_stats;\n"},{"metrics":[{"description":"Current size in bytes of the WAL directory","metric_name":"ccp_wal_activity_total_size_bytes","static_attributes":{"server":"localhost:5432"},"value_column":"total_size_bytes"}],"sql":"SELECT last_5_min_size_bytes,\n  (SELECT COALESCE(sum(size),0) FROM pg_catalog.pg_ls_waldir()) AS total_size_bytes\n  FROM (SELECT COALESCE(sum(size),0) AS last_5_min_size_bytes FROM pg_catalog.pg_ls_waldir() WHERE modification \u003e CURRENT_TIMESTAMP - '5 minutes'::interval) x;\n"},{"metrics":[{"attribute_columns":["dbname","query","queryid","role"],"description":"Epoch time when stats were reset","metric_name":"ccp_pg_stat_statements_top_max_exec_time_ms","static_attributes":{"server":"localhost:5432"},"value_column":"max_exec_time_ms","value_type":"double"}],"sql":"WITH monitor AS (\n  SELECT\n    pg_get_userbyid(s.userid) AS role\n    , d.datname AS dbname\n    , s.queryid AS queryid\n    , btrim(replace(left(s.query, 40), '\\n', '')) AS query\n    , s.calls\n    , s.total_exec_time AS total_exec_time\n    , s.max_exec_time AS max_exec_time_ms\n    , s.rows\n    , s.wal_records AS records\n    , s.wal_fpi AS fpi\n    , s.wal_bytes AS bytes\n  FROM public.pg_stat_statements s\n  JOIN pg_catalog.pg_database d ON d.oid = s.dbid\n) SELECT role\n  , dbname\n  , queryid\n  , query\n  , max_exec_time_ms\n  , records\nFROM monitor ORDER BY 5 DESC LIMIT 20;\n"},{"metrics":[{"attribute_columns":["dbname","query","queryid","role"],"description":"Total time spent in the statement in milliseconds","metric_name":"ccp_pg_stat_statements_top_total_exec_time_ms","static_attributes":{"server":"localhost:5432"},"value_column":"total_exec_time_ms","value_type":"double"}],"sql":"WITH monitor AS (\n  SELECT\n    pg_get_userbyid(s.userid) AS role\n    , d.datname AS dbname\n    , s.queryid AS queryid\n    , btrim(replace(left(s.query, 40), '\\n', '')) AS query\n    , s.calls\n    , s.total_exec_time AS total_exec_time_ms\n    , s.rows\n    , s.wal_records AS records\n    , s.wal_fpi AS fpi\n    , s.wal_bytes AS bytes\n  FROM public.pg_stat_statements s\n  JOIN pg_catalog.pg_database d ON d.oid = s.dbid\n) SELECT role\n  , dbname\n  , queryid\n  , query\n  , total_exec_time_ms\n  , records\nFROM monitor ORDER BY 5 DESC LIMIT 20;\n"},{"metrics":[{"attribute_columns":["dbname","query","queryid","role"],"description":"Total amount of WAL generated by the statement in bytes","metric_name":"ccp_pg_stat_statements_top_wal_bytes","static_attributes":{"server":"localhost:5432"},"value_column":"bytes","value_type":"double"},{"attribute_columns":["dbname","query","queryid","role"],"description":"Total number of WAL full page images generated by the statement","metric_name":"ccp_pg_stat_statements_top_wal_fpi","static_attributes":{"server":"localhost:5432"},"value_column":"fpi","value_type":"double"},{"attribute_columns":["dbname","query","queryid","role"],"description":"Total number of WAL records generated by the statement","metric_name":"ccp_pg_stat_statements_top_wal_records","static_attributes":{"server":"localhost:5432"},"value_column":"records","value_type":"double"}],"sql":"WITH monitor AS (\n  SELECT\n    pg_get_userbyid(s.userid) AS role\n    , d.datname AS dbname\n    , s.queryid AS queryid\n    , btrim(replace(left(s.query, 40), '\\n', '')) AS query\n    , s.calls\n    , s.total_exec_time AS total_exec_time\n    , s.max_exec_time AS max_exec_time\n    , s.mean_exec_time AS mean_exec_time\n    , s.rows\n    , s.wal_records AS records\n    , s.wal_fpi AS fpi\n    , s.wal_bytes AS bytes\n  FROM public.pg_stat_statements s\n  JOIN pg_catalog.pg_database d ON d.oid = s.dbid\n) SELECT role\n  , dbname\n  , query\n  , queryid\n  , records\n  , fpi\n  , bytes\nFROM monitor ORDER BY bytes DESC LIMIT 20;\n"},{"metrics":[{"attribute_columns":["repo"],"description":"Seconds since the last completed full or differential backup. Differential is always based off last full.","metric_name":"ccp_backrest_last_diff_backup_time_since_completion_seconds","static_attributes":{"server":"localhost:5432","stanza":"db"},"value_column":"last_diff_backup"},{"attribute_columns":["repo"],"description":"Seconds since the last completed full backup","metric_name":"ccp_backrest_last_full_backup_time_since_completion_seconds","static_attributes":{"server":"localhost:5432","stanza":"db"},"value_column":"last_full_backup"},{"attribute_columns":["repo"],"description":"Seconds since the last completed full, differential or incremental backup.\nIncremental is always based off last full or differential.\n","metric_name":"ccp_backrest_last_incr_backup_time_since_completion_seconds","static_attributes":{"server":"localhost:5432","stanza":"db"},"value_column":"last_incr_backup"},{"attribute_columns":["backup_type","repo"],"description":"pgBackRest version number when this backup was performed","metric_name":"ccp_backrest_last_info_backrest_repo_version","static_attributes":{"server":"localhost:5432","stanza":"db"},"value_column":"last_info_backrest_repo_version"},{"attribute_columns":["backup_type","repo"],"description":"An error has been encountered in the backup. Check logs for more information.","metric_name":"ccp_backrest_last_info_backup_error","static_attributes":{"server":"localhost:5432","stanza":"db"},"value_column":"last_info_backup_error"},{"attribute_columns":["backup_type","repo"],"description":"Total runtime in seconds of this backup","metric_name":"ccp_backrest_last_info_backup_runtime_seconds","static_attributes":{"server":"localhost:5432","stanza":"db"},"value_column":"backup_runtime_seconds"},{"attribute_columns":["backup_type","repo"],"description":"Actual size of only this individual backup in the pgbackrest repository","metric_name":"ccp_backrest_last_info_repo_backup_size_bytes","static_attributes":{"server":"localhost:5432","stanza":"db"},"value_column":"repo_backup_size_bytes"},{"attribute_columns":["backup_type","repo"],"description":"Total size of this backup in the pgbackrest repository, including all required previous backups and WAL","metric_name":"ccp_backrest_last_info_repo_total_size_bytes","static_attributes":{"server":"localhost:5432","stanza":"db"},"value_column":"repo_total_size_bytes"},{"attribute_columns":["repo"],"description":"Seconds since the oldest completed full backup","metric_name":"ccp_backrest_oldest_full_backup_time_seconds","static_attributes":{"server":"localhost:5432"},"value_column":"oldest_full_backup"}],"sql":"SELECT * FROM get_pgbackrest_info();\n"}]
+[{"metrics":[{"attribute_columns":["application_name","datname","state","usename"],"description":"number of connections in this state","metric_name":"ccp_pg_stat_activity_count","static_attributes":{"server":"localhost:5432"},"value_column":"count"}],"sql":"SELECT\n    pg_database.datname,\n    tmp.state,\n    COALESCE(tmp2.usename, '') as usename,\n    COALESCE(tmp2.application_name, '') as application_name,\n    COALESCE(count,0) as count,\n    COALESCE(max_tx_duration,0) as max_tx_duration\nFROM\n    (\n      VALUES ('active'),\n             ('idle'),\n             ('idle in transaction'),\n             ('idle in transaction (aborted)'),\n             ('fastpath function call'),\n             ('disabled')\n    ) AS tmp(state) CROSS JOIN pg_database\nLEFT JOIN (\n    SELECT\n        datname,\n        state,\n        usename,\n        application_name,\n        count(*) AS count,\n        MAX(EXTRACT(EPOCH FROM now() - xact_start))::float AS max_tx_duration\n    FROM pg_stat_activity GROUP BY datname,state,usename,application_name) AS tmp2\n    ON tmp.state = tmp2.state AND pg_database.datname = tmp2.datname;\n"},{"metrics":[{"description":"Seconds since the last successful archive operation","metric_name":"ccp_archive_command_status_seconds_since_last_archive","static_attributes":{"server":"localhost:5432"},"value_column":"seconds_since_last_archive","value_type":"double"}],"sql":"SELECT COALESCE(EXTRACT(epoch from (CURRENT_TIMESTAMP - last_archived_time)), 0) AS seconds_since_last_archive FROM pg_catalog.pg_stat_archiver;\n"},{"metrics":[{"description":"Number of WAL files that have been successfully archived","metric_name":"ccp_archive_command_status_archived_count","static_attributes":{"server":"localhost:5432"},"value_column":"archived_count"}],"sql":"SELECT archived_count FROM pg_catalog.pg_stat_archiver\n"},{"metrics":[{"description":"Number of failed attempts for archiving WAL files","metric_name":"ccp_archive_command_status_failed_count","static_attributes":{"server":"localhost:5432"},"value_column":"failed_count"}],"sql":"SELECT failed_count FROM pg_catalog.pg_stat_archiver\n"},{"metrics":[{"description":"Seconds since the last recorded failure of the archive_command","metric_name":"ccp_archive_command_status_seconds_since_last_fail","static_attributes":{"server":"localhost:5432"},"value_column":"seconds_since_last_fail"}],"sql":"SELECT CASE\n    WHEN EXTRACT(epoch from (last_failed_time - last_archived_time)) IS NULL THEN 0\n    WHEN EXTRACT(epoch from (last_failed_time - last_archived_time)) \u003c 0 THEN 0\n    ELSE EXTRACT(epoch from (last_failed_time - last_archived_time))\n    END AS seconds_since_last_fail\nFROM pg_catalog.pg_stat_archiver\n"},{"metrics":[{"description":"Total non-idle connections","metric_name":"ccp_connection_stats_active","static_attributes":{"server":"localhost:5432"},"value_column":"active"},{"description":"Total idle connections","metric_name":"ccp_connection_stats_idle","static_attributes":{"server":"localhost:5432"},"value_column":"idle"},{"description":"Total idle in transaction connections","metric_name":"ccp_connection_stats_idle_in_txn","static_attributes":{"server":"localhost:5432"},"value_column":"idle_in_txn"},{"description":"Value of max_connections for the monitored database","metric_name":"ccp_connection_stats_max_blocked_query_time","static_attributes":{"server":"localhost:5432"},"value_column":"max_blocked_query_time","value_type":"double"},{"description":"Value of max_connections for the monitored database","metric_name":"ccp_connection_stats_max_connections","static_attributes":{"server":"localhost:5432"},"value_column":"max_connections"},{"description":"Length of time in seconds of the longest idle in transaction session","metric_name":"ccp_connection_stats_max_idle_in_txn_time","static_attributes":{"server":"localhost:5432"},"value_column":"max_idle_in_txn_time","value_type":"double"},{"description":"Length of time in seconds of the longest running query","metric_name":"ccp_connection_stats_max_query_time","static_attributes":{"server":"localhost:5432"},"value_column":"max_query_time","value_type":"double"},{"description":"Total idle and non-idle connections","metric_name":"ccp_connection_stats_total","static_attributes":{"server":"localhost:5432"},"value_column":"total"}],"sql":"SELECT ((total - idle) - idle_in_txn) as active\n    , total\n    , idle\n    , idle_in_txn\n    , (SELECT COALESCE(EXTRACT(epoch FROM (MAX(clock_timestamp() - state_change))),0) FROM pg_catalog.pg_stat_activity WHERE state = 'idle in transaction') AS max_idle_in_txn_time\n    , (SELECT COALESCE(EXTRACT(epoch FROM (MAX(clock_timestamp() - query_start))),0) FROM pg_catalog.pg_stat_activity WHERE backend_type = 'client backend' AND state \u003c\u003e 'idle' ) AS max_query_time\n    , (SELECT COALESCE(EXTRACT(epoch FROM (MAX(clock_timestamp() - query_start))),0) FROM pg_catalog.pg_stat_activity WHERE backend_type = 'client backend' AND wait_event_type = 'Lock' ) AS max_blocked_query_time\n    , max_connections\n    FROM (\n            SELECT COUNT(*) as total\n                    , COALESCE(SUM(CASE WHEN state = 'idle' THEN 1 ELSE 0 END),0) AS idle\n                    , COALESCE(SUM(CASE WHEN state = 'idle in transaction' THEN 1 ELSE 0 END),0) AS idle_in_txn FROM pg_catalog.pg_stat_activity) x\n    JOIN (SELECT setting::float AS max_connections FROM pg_settings WHERE name = 'max_connections') xx ON (true);\n"},{"metrics":[{"attribute_columns":["dbname"],"description":"Total number of checksum failures on this database","metric_name":"ccp_data_checksum_failure_count","static_attributes":{"server":"localhost:5432"},"value_column":"count"},{"attribute_columns":["dbname"],"description":"Time interval in seconds since the last checksum failure was encountered","metric_name":"ccp_data_checksum_failure_time_since_last_failure_seconds","static_attributes":{"server":"localhost:5432"},"value_column":"time_since_last_failure_seconds","value_type":"double"}],"sql":"SELECT datname AS dbname , checksum_failures AS count , coalesce(extract(epoch from (clock_timestamp() - checksum_last_failure)), 0) AS time_since_last_failure_seconds FROM pg_catalog.pg_stat_database WHERE pg_stat_database.datname IS NOT NULL;\n"},{"metrics":[{"attribute_columns":["dbname","mode"],"description":"Number of locks per mode type","metric_name":"ccp_locks_count","static_attributes":{"server":"localhost:5432"},"value_column":"count"}],"sql":"SELECT pg_database.datname as dbname , tmp.mode , COALESCE(count,0) as count FROM (\n  VALUES ('accesssharelock'),\n         ('rowsharelock'),\n         ('rowexclusivelock'),\n         ('shareupdateexclusivelock'),\n         ('sharelock'),\n         ('sharerowexclusivelock'),\n         ('exclusivelock'),\n         ('accessexclusivelock')\n) AS tmp(mode) CROSS JOIN pg_catalog.pg_database LEFT JOIN\n    (SELECT database, lower(mode) AS mode,count(*) AS count\n    FROM pg_catalog.pg_locks WHERE database IS NOT NULL\n    GROUP BY database, lower(mode)\n) AS tmp2 ON tmp.mode=tmp2.mode and pg_database.oid = tmp2.database;\n"},{"metrics":[{"description":"CPU limit value in milli cores","metric_name":"ccp_nodemx_cpu_limit","static_attributes":{"server":"localhost:5432"},"value_column":"limit"},{"description":"CPU request value in milli cores","metric_name":"ccp_nodemx_cpu_request","static_attributes":{"server":"localhost:5432"},"value_column":"request"}],"sql":"SELECT monitor.kdapi_scalar_bigint('cpu_request') AS request , monitor.kdapi_scalar_bigint('cpu_limit') AS limit\n"},{"metrics":[{"description":"CPU usage in nanoseconds","metric_name":"ccp_nodemx_cpuacct_usage","static_attributes":{"server":"localhost:5432"},"value_column":"usage","value_type":"double"},{"description":"CPU usage snapshot timestamp","metric_name":"ccp_nodemx_cpuacct_usage_ts","static_attributes":{"server":"localhost:5432"},"value_column":"usage_ts","value_type":"double"}],"sql":"SELECT CASE WHEN monitor.cgroup_mode() = 'legacy'\n  THEN monitor.cgroup_scalar_bigint('cpuacct.usage')\n  ELSE (SELECT val FROM monitor.cgroup_setof_kv('cpu.stat') where key = 'usage_usec') * 1000\n  END AS usage,\n  extract(epoch from clock_timestamp()) AS usage_ts;\n"},{"metrics":[{"description":"The total available run-time within a period (in microseconds)","metric_name":"ccp_nodemx_cpucfs_period_us","static_attributes":{"server":"localhost:5432"},"value_column":"period_us"},{"description":"The length of a period (in microseconds)","metric_name":"ccp_nodemx_cpucfs_quota_us","static_attributes":{"server":"localhost:5432"},"value_column":"quota_us","value_type":"double"}],"sql":"SELECT\n  CASE\n  WHEN monitor.cgroup_mode() = 'legacy' THEN\n    monitor.cgroup_scalar_bigint('cpu.cfs_period_us')\n  ELSE\n    (monitor.cgroup_array_bigint('cpu.max'))[2]\n  END AS period_us,\n  CASE\n  WHEN monitor.cgroup_mode() = 'legacy' THEN\n    GREATEST(monitor.cgroup_scalar_bigint('cpu.cfs_quota_us'), 0)\n  ELSE\n    GREATEST((monitor.cgroup_array_bigint('cpu.max'))[1], 0)\n  END AS quota_us;\n"},{"metrics":[{"description":"Number of periods that any thread was runnable","metric_name":"ccp_nodemx_cpustat_nr_periods","static_attributes":{"server":"localhost:5432"},"value_column":"nr_periods","value_type":"double"},{"description":"Number of runnable periods in which the application used its entire quota and was throttled","metric_name":"ccp_nodemx_cpustat_nr_throttled","static_attributes":{"server":"localhost:5432"},"value_column":"nr_throttled"},{"description":"CPU stat snapshot timestamp","metric_name":"ccp_nodemx_cpustat_snap_ts","static_attributes":{"server":"localhost:5432"},"value_column":"snap_ts","value_type":"double"},{"description":"Sum total amount of time individual threads within the monitor.cgroup were throttled","metric_name":"ccp_nodemx_cpustat_throttled_time","static_attributes":{"server":"localhost:5432"},"value_column":"throttled_time","value_type":"double"}],"sql":"WITH d(key, val) AS (select key, val from monitor.cgroup_setof_kv('cpu.stat')) SELECT\n (SELECT val FROM d WHERE key='nr_periods') AS nr_periods,\n (SELECT val FROM d WHERE key='nr_throttled') AS nr_throttled,\n (SELECT val FROM d WHERE key='throttled_usec') AS throttled_time,\n extract(epoch from clock_timestamp()) as snap_ts;\n"},{"metrics":[{"attribute_columns":["fs_type","mount_point"],"description":"Available size in bytes","metric_name":"ccp_nodemx_data_disk_available_bytes","static_attributes":{"server":"localhost:5432"},"value_column":"available_bytes","value_type":"double"},{"attribute_columns":["fs_type","mount_point"],"description":"Available file nodes","metric_name":"ccp_nodemx_data_disk_free_file_nodes","static_attributes":{"server":"localhost:5432"},"value_column":"free_file_nodes"},{"attribute_columns":["fs_type","mount_point"],"description":"Size in bytes","metric_name":"ccp_nodemx_data_disk_total_bytes","static_attributes":{"server":"localhost:5432"},"value_column":"total_bytes"},{"attribute_columns":["fs_type","mount_point"],"description":"Total file nodes","metric_name":"ccp_nodemx_data_disk_total_file_nodes","static_attributes":{"server":"localhost:5432"},"value_column":"total_file_nodes"}],"sql":"SELECT mount_point,fs_type,total_bytes,available_bytes,total_file_nodes,free_file_nodes\n          FROM monitor.proc_mountinfo() m\n          JOIN monitor.fsinfo(m.mount_point) f USING (major_number, minor_number)\n          WHERE m.mount_point IN ('/pgdata', '/pgwal') OR\n                m.mount_point like '/tablespaces/%'\n"},{"metrics":[{"attribute_columns":["mount_point"],"description":"Total sectors read","metric_name":"ccp_nodemx_disk_activity_sectors_read","static_attributes":{"server":"localhost:5432"},"value_column":"sectors_read"},{"attribute_columns":["mount_point"],"description":"Total sectors written","metric_name":"ccp_nodemx_disk_activity_sectors_written","static_attributes":{"server":"localhost:5432"},"value_column":"sectors_written"}],"sql":"SELECT mount_point,sectors_read,sectors_written\n          FROM monitor.proc_mountinfo() m\n          JOIN monitor.proc_diskstats() d USING (major_number, minor_number)\n          WHERE m.mount_point IN ('/pgdata', '/pgwal') OR\n                m.mount_point like '/tablespaces/%';\n"},{"metrics":[{"description":"Total bytes of anonymous and swap cache memory on active LRU list","metric_name":"ccp_nodemx_mem_active_anon","static_attributes":{"server":"localhost:5432"},"value_column":"active_anon","value_type":"double"},{"description":"Total bytes of file-backed memory on active LRU list","metric_name":"ccp_nodemx_mem_active_file","static_attributes":{"server":"localhost:5432"},"value_column":"active_file","value_type":"double"},{"description":"Total bytes of page cache memory","metric_name":"ccp_nodemx_mem_cache","static_attributes":{"server":"localhost:5432"},"value_column":"cache","value_type":"double"},{"description":"Total bytes that are waiting to get written back to the disk","metric_name":"ccp_nodemx_mem_dirty","static_attributes":{"server":"localhost:5432"},"value_column":"dirty"},{"description":"Total bytes of anonymous and swap cache memory on inactive LRU list","metric_name":"ccp_nodemx_mem_inactive_anon","static_attributes":{"server":"localhost:5432"},"value_column":"inactive_anon","value_type":"double"},{"description":"Total bytes of file-backed memory on inactive LRU list","metric_name":"ccp_nodemx_mem_inactive_file","static_attributes":{"server":"localhost:5432"},"value_column":"inactive_file","value_type":"double"},{"description":"Unknown metric from ccp_nodemx_mem","metric_name":"ccp_nodemx_mem_kmem_usage_in_byte","static_attributes":{"server":"localhost:5432"},"value_column":"kmem_usage_in_byte"},{"description":"Memory limit value in bytes","metric_name":"ccp_nodemx_mem_limit","static_attributes":{"server":"localhost:5432"},"value_column":"limit"},{"description":"Total bytes of mapped file (includes tmpfs/shmem)","metric_name":"ccp_nodemx_mem_mapped_file","static_attributes":{"server":"localhost:5432"},"value_column":"mapped_file"},{"description":"Memory request value in bytes","metric_name":"ccp_nodemx_mem_request","static_attributes":{"server":"localhost:5432"},"value_column":"request"},{"description":"Total bytes of anonymous and swap cache memory","metric_name":"ccp_nodemx_mem_rss","static_attributes":{"server":"localhost:5432"},"value_column":"rss","value_type":"double"},{"description":"Total bytes of shared memory","metric_name":"ccp_nodemx_mem_shmem","static_attributes":{"server":"localhost:5432"},"value_column":"shmem","value_type":"double"},{"description":"Total usage in bytes","metric_name":"ccp_nodemx_mem_usage_in_bytes","static_attributes":{"server":"localhost:5432"},"value_column":"usage_in_bytes"}],"sql":"WITH d(key, val) as (SELECT key, val FROM monitor.cgroup_setof_kv('memory.stat')) SELECT\n  monitor.kdapi_scalar_bigint('mem_request') AS request,\n  CASE\n    WHEN monitor.cgroup_mode() = 'legacy' THEN\n        (CASE WHEN monitor.cgroup_scalar_bigint('memory.limit_in_bytes') = 9223372036854771712 THEN 0 ELSE monitor.cgroup_scalar_bigint('memory.limit_in_bytes') END)\n    ELSE\n        (CASE WHEN monitor.cgroup_scalar_bigint('memory.max') = 9223372036854775807 THEN 0 ELSE monitor.cgroup_scalar_bigint('memory.max') END)\n  END AS limit,\n  CASE\n    WHEN monitor.cgroup_mode() = 'legacy'\n    THEN (SELECT val FROM d WHERE key='cache')\n    ELSE 0\n  END as cache,\n  CASE\n    WHEN monitor.cgroup_mode() = 'legacy'\n    THEN (SELECT val FROM d WHERE key='rss')\n    ELSE 0\n  END as RSS,\n  (SELECT val FROM d WHERE key='shmem') as shmem,\n  CASE\n    WHEN monitor.cgroup_mode() = 'legacy'\n    THEN (SELECT val FROM d WHERE key='mapped_file')\n    ELSE 0\n  END as mapped_file,\n  CASE\n    WHEN monitor.cgroup_mode() = 'legacy'\n    THEN (SELECT val FROM d WHERE key='dirty')\n    ELSE (SELECT val FROM d WHERE key='file_dirty')\n  END as dirty,\n  (SELECT val FROM d WHERE key='active_anon') as active_anon,\n  (SELECT val FROM d WHERE key='inactive_anon') as inactive_anon,\n  (SELECT val FROM d WHERE key='active_file') as active_file,\n  (SELECT val FROM d WHERE key='inactive_file') as inactive_file,\n  CASE\n    WHEN monitor.cgroup_mode() = 'legacy'\n    THEN monitor.cgroup_scalar_bigint('memory.usage_in_bytes')\n    ELSE monitor.cgroup_scalar_bigint('memory.current')\n  END as usage_in_bytes,\n  CASE\n    WHEN monitor.cgroup_mode() = 'legacy'\n    THEN monitor.cgroup_scalar_bigint('memory.kmem.usage_in_bytes')\n    ELSE 0\n  END as kmem_usage_in_byte;\n"},{"metrics":[{"attribute_columns":["interface"],"description":"Number of bytes received","metric_name":"ccp_nodemx_network_rx_bytes","static_attributes":{"server":"localhost:5432"},"value_column":"rx_bytes"},{"attribute_columns":["interface"],"description":"Number of packets received","metric_name":"ccp_nodemx_network_rx_packets","static_attributes":{"server":"localhost:5432"},"value_column":"rx_packets"},{"attribute_columns":["interface"],"description":"Number of bytes transmitted","metric_name":"ccp_nodemx_network_tx_bytes","static_attributes":{"server":"localhost:5432"},"value_column":"tx_bytes"},{"attribute_columns":["interface"],"description":"Number of packets transmitted","metric_name":"ccp_nodemx_network_tx_packets","static_attributes":{"server":"localhost:5432"},"value_column":"tx_packets"}],"sql":"SELECT interface\n  ,tx_bytes\n  ,tx_packets\n  ,rx_bytes\n  ,rx_packets from monitor.proc_network_stats()\n"},{"metrics":[{"description":"Total number of database processes","metric_name":"ccp_nodemx_process_count","static_attributes":{"server":"localhost:5432"},"value_column":"count"}],"sql":"SELECT monitor.cgroup_process_count() as count;\n"},{"metrics":[{"description":"Epoch time when stats were reset","metric_name":"ccp_pg_stat_statements_reset_time","static_attributes":{"server":"localhost:5432"},"value_column":"time"}],"sql":"SELECT monitor.pg_stat_statements_reset_info(-1) as time;\n"},{"metrics":[{"attribute_columns":["dbname","query","queryid","role"],"description":"Average query runtime in milliseconds","metric_name":"ccp_pg_stat_statements_top_mean_exec_time_ms","static_attributes":{"server":"localhost:5432"},"value_column":"top_mean_exec_time_ms","value_type":"double"}],"sql":"WITH monitor AS (\n  SELECT\n    pg_get_userbyid(s.userid) AS role\n    , d.datname AS dbname\n    , s.queryid AS queryid\n    , btrim(replace(left(s.query, 40), '\\n', '')) AS query\n    , s.calls\n    , s.total_exec_time AS total_exec_time\n    , s.max_exec_time AS max_exec_time\n    , s.mean_exec_time AS mean_exec_time\n    , s.rows\n    , s.wal_records AS records\n    , s.wal_fpi AS fpi\n    , s.wal_bytes AS bytes\n  FROM public.pg_stat_statements s\n  JOIN pg_catalog.pg_database d ON d.oid = s.dbid\n) SELECT role\n  , dbname\n  , queryid\n  , query\n  , max(monitor.mean_exec_time) AS top_mean_exec_time_ms\nFROM monitor GROUP BY 1,2,3,4 ORDER BY 5 DESC LIMIT 20;\n"},{"metrics":[{"attribute_columns":["dbname","role"],"description":"Total number of queries run per user/database","metric_name":"ccp_pg_stat_statements_total_calls_count","static_attributes":{"server":"localhost:5432"},"value_column":"calls_count","value_type":"double"},{"attribute_columns":["dbname","role"],"description":"Total runtime of all queries per user/database","metric_name":"ccp_pg_stat_statements_total_exec_time_ms","static_attributes":{"server":"localhost:5432"},"value_column":"exec_time_ms","value_type":"double"},{"attribute_columns":["dbname","role"],"description":"Total runtime of all queries per user/database","metric_name":"ccp_pg_stat_statements_total_mean_exec_time_ms","static_attributes":{"server":"localhost:5432"},"value_column":"mean_exec_time_ms","value_type":"double"},{"attribute_columns":["dbname","role"],"description":"Total rows returned from all queries per user/database","metric_name":"ccp_pg_stat_statements_total_row_count","static_attributes":{"server":"localhost:5432"},"value_column":"row_count","value_type":"double"}],"sql":"WITH monitor AS (\n  SELECT\n    pg_get_userbyid(s.userid) AS role\n    , d.datname AS dbname\n    , s.calls\n    , s.total_exec_time\n    , s.mean_exec_time\n    , s.rows\n  FROM public.pg_stat_statements s\n  JOIN pg_catalog.pg_database d ON d.oid = s.dbid\n) SELECT role\n  , dbname\n  , sum(calls) AS calls_count\n  , sum(total_exec_time) AS exec_time_ms\n  , avg(mean_exec_time) AS mean_exec_time_ms\n  , sum(rows) AS row_count\nFROM monitor GROUP BY 1,2;\n"},{"metrics":[{"description":"The current version of PostgreSQL that this exporter is running on as a 6 digit integer (######).","metric_name":"ccp_postgresql_version_current","static_attributes":{"server":"localhost:5432"},"value_column":"current"}],"sql":"SELECT current_setting('server_version_num')::int AS current;\n"},{"metrics":[{"description":"Time interval in seconds since PostgreSQL database was last restarted.","metric_name":"ccp_postmaster_uptime_seconds","static_attributes":{"server":"localhost:5432"},"value_column":"seconds","value_type":"double"}],"sql":"SELECT extract(epoch from (clock_timestamp() - pg_postmaster_start_time() )) AS seconds;\n"},{"metrics":[{"description":"Time interval in seconds since PostgreSQL database was last restarted.","metric_name":"ccp_replication_lag_size_bytes","static_attributes":{"server":"localhost:5432"},"value_column":"bytes","value_type":"double"}],"sql":"SELECT * FROM get_replication_lag();\n"},{"metrics":[{"description":"Return value of 1 means database is in recovery. Otherwise 2 it is a primary","metric_name":"ccp_is_in_recovery_status","static_attributes":{"server":"localhost:5432"},"value_column":"status","value_type":"double"},{"attribute_columns":["role"],"description":"Length of time since the last WAL file was received and replayed on replica.\nAlways increases, possibly causing false positives if the primary stops writing.\nMonitors for replicas that stop receiving WAL all together.\n","metric_name":"ccp_replication_lag_received_time","static_attributes":{"server":"localhost:5432"},"value_column":"received_time","value_type":"double"},{"attribute_columns":["role"],"description":"Length of time since the last transaction was replayed on replica.\nReturns zero if last WAL received equals last WAL replayed. Avoids\nfalse positives when primary stops writing. Monitors for replicas that\ncannot keep up with primary WAL generation.\n","metric_name":"ccp_replication_lag_replay_time","static_attributes":{"server":"localhost:5432"},"value_column":"replay_time","value_type":"double"}],"sql":"SELECT\n   COALESCE(\n      CASE\n         WHEN (pg_last_wal_receive_lsn() = pg_last_wal_replay_lsn()) OR (pg_is_in_recovery() = false) THEN 0\n         ELSE EXTRACT (EPOCH FROM clock_timestamp() - pg_last_xact_replay_timestamp())::INTEGER\n      END,\n      0\n   ) AS replay_time,\n   COALESCE(\n      CASE\n         WHEN pg_is_in_recovery() = false THEN 0\n         ELSE EXTRACT (EPOCH FROM clock_timestamp() - pg_last_xact_replay_timestamp())::INTEGER\n      END,\n      0\n   ) AS received_time,\n   CASE\n      WHEN pg_is_in_recovery() = true THEN 'replica'\n      ELSE 'primary'\n   END AS role,\n   CASE\n      WHEN pg_is_in_recovery() = true THEN 1\n      ELSE 2\n   END AS status;\n"},{"metrics":[{"description":"Number of settings from pg_settings catalog in a pending_restart state","metric_name":"ccp_settings_pending_restart_count","static_attributes":{"server":"localhost:5432"},"value_column":"count"}],"sql":"SELECT count(*) AS count FROM pg_catalog.pg_settings WHERE pending_restart = true;\n"},{"metrics":[{"description":"Number of buffers allocated","metric_name":"ccp_stat_bgwriter_buffers_alloc","static_attributes":{"server":"localhost:5432"},"value_column":"buffers_alloc"},{"data_type":"sum","description":"Number of buffers written by the background writer","metric_name":"ccp_stat_bgwriter_buffers_clean","static_attributes":{"server":"localhost:5432"},"value_column":"buffers_clean"},{"description":"Number of times the background writer stopped a cleaning scan because it had written too many buffers","metric_name":"ccp_stat_bgwriter_maxwritten_clean","static_attributes":{"server":"localhost:5432"},"value_column":"maxwritten_clean"}],"sql":"SELECT\n    buffers_clean\n    , maxwritten_clean\n    , buffers_alloc\nFROM pg_catalog.pg_stat_bgwriter;\n"},{"metrics":[{"description":"Oldest current transaction ID in cluster","metric_name":"ccp_transaction_wraparound_oldest_current_xid","static_attributes":{"server":"localhost:5432"},"value_column":"oldest_current_xid"},{"description":"Percentage towards emergency autovacuum process starting","metric_name":"ccp_transaction_wraparound_percent_towards_emergency_autovac","static_attributes":{"server":"localhost:5432"},"value_column":"percent_towards_emergency_autovac"},{"description":"Percentage towards transaction ID wraparound","metric_name":"ccp_transaction_wraparound_percent_towards_wraparound","static_attributes":{"server":"localhost:5432"},"value_column":"percent_towards_wraparound"}],"sql":"WITH max_age AS (\n    SELECT 2000000000 as max_old_xid\n    , setting AS autovacuum_freeze_max_age\n    FROM pg_catalog.pg_settings\n    WHERE name = 'autovacuum_freeze_max_age')\n, per_database_stats AS (\n    SELECT datname\n    , m.max_old_xid::int\n    , m.autovacuum_freeze_max_age::int\n    , age(d.datfrozenxid) AS oldest_current_xid\n    FROM pg_catalog.pg_database d\n    JOIN max_age m ON (true)\n    WHERE d.datallowconn)\nSELECT max(oldest_current_xid) AS oldest_current_xid , max(ROUND(100*(oldest_current_xid/max_old_xid::float))) AS percent_towards_wraparound , max(ROUND(100*(oldest_current_xid/autovacuum_freeze_max_age::float))) AS percent_towards_emergency_autovac FROM per_database_stats;\n"},{"metrics":[{"description":"Current size in bytes of the WAL directory","metric_name":"ccp_wal_activity_total_size_bytes","static_attributes":{"server":"localhost:5432"},"value_column":"total_size_bytes"}],"sql":"SELECT last_5_min_size_bytes,\n  (SELECT COALESCE(sum(size),0) FROM pg_catalog.pg_ls_waldir()) AS total_size_bytes\n  FROM (SELECT COALESCE(sum(size),0) AS last_5_min_size_bytes FROM pg_catalog.pg_ls_waldir() WHERE modification \u003e CURRENT_TIMESTAMP - '5 minutes'::interval) x;\n"},{"metrics":[{"attribute_columns":["dbname","query","queryid","role"],"description":"Epoch time when stats were reset","metric_name":"ccp_pg_stat_statements_top_max_exec_time_ms","static_attributes":{"server":"localhost:5432"},"value_column":"max_exec_time_ms","value_type":"double"}],"sql":"WITH monitor AS (\n  SELECT\n    pg_get_userbyid(s.userid) AS role\n    , d.datname AS dbname\n    , s.queryid AS queryid\n    , btrim(replace(left(s.query, 40), '\\n', '')) AS query\n    , s.calls\n    , s.total_exec_time AS total_exec_time\n    , s.max_exec_time AS max_exec_time_ms\n    , s.rows\n    , s.wal_records AS records\n    , s.wal_fpi AS fpi\n    , s.wal_bytes AS bytes\n  FROM public.pg_stat_statements s\n  JOIN pg_catalog.pg_database d ON d.oid = s.dbid\n) SELECT role\n  , dbname\n  , queryid\n  , query\n  , max_exec_time_ms\n  , records\nFROM monitor ORDER BY 5 DESC LIMIT 20;\n"},{"metrics":[{"attribute_columns":["dbname","query","queryid","role"],"description":"Total time spent in the statement in milliseconds","metric_name":"ccp_pg_stat_statements_top_total_exec_time_ms","static_attributes":{"server":"localhost:5432"},"value_column":"total_exec_time_ms","value_type":"double"}],"sql":"WITH monitor AS (\n  SELECT\n    pg_get_userbyid(s.userid) AS role\n    , d.datname AS dbname\n    , s.queryid AS queryid\n    , btrim(replace(left(s.query, 40), '\\n', '')) AS query\n    , s.calls\n    , s.total_exec_time AS total_exec_time_ms\n    , s.rows\n    , s.wal_records AS records\n    , s.wal_fpi AS fpi\n    , s.wal_bytes AS bytes\n  FROM public.pg_stat_statements s\n  JOIN pg_catalog.pg_database d ON d.oid = s.dbid\n) SELECT role\n  , dbname\n  , queryid\n  , query\n  , total_exec_time_ms\n  , records\nFROM monitor ORDER BY 5 DESC LIMIT 20;\n"},{"metrics":[{"attribute_columns":["dbname","query","queryid","role"],"description":"Total amount of WAL generated by the statement in bytes","metric_name":"ccp_pg_stat_statements_top_wal_bytes","static_attributes":{"server":"localhost:5432"},"value_column":"bytes","value_type":"double"},{"attribute_columns":["dbname","query","queryid","role"],"description":"Total number of WAL full page images generated by the statement","metric_name":"ccp_pg_stat_statements_top_wal_fpi","static_attributes":{"server":"localhost:5432"},"value_column":"fpi","value_type":"double"},{"attribute_columns":["dbname","query","queryid","role"],"description":"Total number of WAL records generated by the statement","metric_name":"ccp_pg_stat_statements_top_wal_records","static_attributes":{"server":"localhost:5432"},"value_column":"records","value_type":"double"}],"sql":"WITH monitor AS (\n  SELECT\n    pg_get_userbyid(s.userid) AS role\n    , d.datname AS dbname\n    , s.queryid AS queryid\n    , btrim(replace(left(s.query, 40), '\\n', '')) AS query\n    , s.calls\n    , s.total_exec_time AS total_exec_time\n    , s.max_exec_time AS max_exec_time\n    , s.mean_exec_time AS mean_exec_time\n    , s.rows\n    , s.wal_records AS records\n    , s.wal_fpi AS fpi\n    , s.wal_bytes AS bytes\n  FROM public.pg_stat_statements s\n  JOIN pg_catalog.pg_database d ON d.oid = s.dbid\n) SELECT role\n  , dbname\n  , query\n  , queryid\n  , records\n  , fpi\n  , bytes\nFROM monitor ORDER BY bytes DESC LIMIT 20;\n"},{"metrics":[{"attribute_columns":["repo"],"description":"Seconds since the last completed full or differential backup. Differential is always based off last full.","metric_name":"ccp_backrest_last_diff_backup_time_since_completion_seconds","static_attributes":{"server":"localhost:5432","stanza":"db"},"value_column":"last_diff_backup"},{"attribute_columns":["repo"],"description":"Seconds since the last completed full backup","metric_name":"ccp_backrest_last_full_backup_time_since_completion_seconds","static_attributes":{"server":"localhost:5432","stanza":"db"},"value_column":"last_full_backup"},{"attribute_columns":["repo"],"description":"Seconds since the last completed full, differential or incremental backup.\nIncremental is always based off last full or differential.\n","metric_name":"ccp_backrest_last_incr_backup_time_since_completion_seconds","static_attributes":{"server":"localhost:5432","stanza":"db"},"value_column":"last_incr_backup"},{"attribute_columns":["backup_type","repo"],"description":"pgBackRest version number when this backup was performed","metric_name":"ccp_backrest_last_info_backrest_repo_version","static_attributes":{"server":"localhost:5432","stanza":"db"},"value_column":"last_info_backrest_repo_version"},{"attribute_columns":["backup_type","repo"],"description":"An error has been encountered in the backup. Check logs for more information.","metric_name":"ccp_backrest_last_info_backup_error","static_attributes":{"server":"localhost:5432","stanza":"db"},"value_column":"last_info_backup_error"},{"attribute_columns":["backup_type","repo"],"description":"Total runtime in seconds of this backup","metric_name":"ccp_backrest_last_info_backup_runtime_seconds","static_attributes":{"server":"localhost:5432","stanza":"db"},"value_column":"backup_runtime_seconds"},{"attribute_columns":["backup_type","repo"],"description":"Actual size of only this individual backup in the pgbackrest repository","metric_name":"ccp_backrest_last_info_repo_backup_size_bytes","static_attributes":{"server":"localhost:5432","stanza":"db"},"value_column":"repo_backup_size_bytes"},{"attribute_columns":["backup_type","repo"],"description":"Total size of this backup in the pgbackrest repository, including all required previous backups and WAL","metric_name":"ccp_backrest_last_info_repo_total_size_bytes","static_attributes":{"server":"localhost:5432","stanza":"db"},"value_column":"repo_total_size_bytes"},{"attribute_columns":["repo"],"description":"Seconds since the oldest completed full backup","metric_name":"ccp_backrest_oldest_full_backup_time_seconds","static_attributes":{"server":"localhost:5432"},"value_column":"oldest_full_backup"}],"sql":"SELECT * FROM get_pgbackrest_info();\n"},{"metrics":[{"attribute_columns":["dbname"],"description":"Number of times disk blocks were found already in the buffer cache, so that a read was not necessary","metric_name":"ccp_stat_database_blks_hit","static_attributes":{"server":"localhost:5432"},"value_column":"blks_hit"},{"attribute_columns":["dbname"],"description":"Number of disk blocks read in this database","metric_name":"ccp_stat_database_blks_read","static_attributes":{"server":"localhost:5432"},"value_column":"blks_read"},{"attribute_columns":["dbname"],"description":"Number of queries canceled due to conflicts with recovery in this database","metric_name":"ccp_stat_database_conflicts","static_attributes":{"server":"localhost:5432"},"value_column":"conflicts"},{"attribute_columns":["dbname"],"description":"Number of deadlocks detected in this database","metric_name":"ccp_stat_database_deadlocks","static_attributes":{"server":"localhost:5432"},"value_column":"deadlocks"},{"attribute_columns":["dbname"],"description":"Total amount of data written to temporary files by queries in this database","metric_name":"ccp_stat_database_temp_bytes","static_attributes":{"server":"localhost:5432"},"value_column":"temp_bytes"},{"attribute_columns":["dbname"],"description":"Number of rows deleted by queries in this database","metric_name":"ccp_stat_database_temp_files","static_attributes":{"server":"localhost:5432"},"value_column":"temp_files"},{"attribute_columns":["dbname"],"description":"Number of rows deleted by queries in this database","metric_name":"ccp_stat_database_tup_deleted","static_attributes":{"server":"localhost:5432"},"value_column":"tup_deleted"},{"attribute_columns":["dbname"],"description":"Number of rows fetched by queries in this database","metric_name":"ccp_stat_database_tup_fetched","static_attributes":{"server":"localhost:5432"},"value_column":"tup_fetched"},{"attribute_columns":["dbname"],"description":"Number of rows inserted by queries in this database","metric_name":"ccp_stat_database_tup_inserted","static_attributes":{"server":"localhost:5432"},"value_column":"tup_inserted"},{"attribute_columns":["dbname"],"description":"Number of rows returned by queries in this database","metric_name":"ccp_stat_database_tup_returned","static_attributes":{"server":"localhost:5432"},"value_column":"tup_returned"},{"attribute_columns":["dbname"],"description":"Number of rows updated by queries in this database","metric_name":"ccp_stat_database_tup_updated","static_attributes":{"server":"localhost:5432"},"value_column":"tup_updated"},{"attribute_columns":["dbname"],"description":"Number of transactions in this database that have been committed","metric_name":"ccp_stat_database_xact_commit","static_attributes":{"server":"localhost:5432"},"value_column":"xact_commit"},{"attribute_columns":["dbname"],"description":"Number of transactions in this database that have been rolled back","metric_name":"ccp_stat_database_xact_rollback","static_attributes":{"server":"localhost:5432"},"value_column":"xact_rollback"}],"sql":"SELECT s.datname AS dbname , s.xact_commit , s.xact_rollback , s.blks_read , s.blks_hit , s.tup_returned , s.tup_fetched , s.tup_inserted , s.tup_updated , s.tup_deleted , s.conflicts , s.temp_files , s.temp_bytes , s.deadlocks FROM pg_catalog.pg_stat_database s JOIN pg_catalog.pg_database d ON d.datname = s.datname WHERE d.datistemplate = false;\n"}]
diff --git a/internal/collector/gte_pg16_metrics.yaml b/internal/collector/gte_pg16_slow_metrics.yaml
similarity index 100%
rename from internal/collector/gte_pg16_metrics.yaml
rename to internal/collector/gte_pg16_slow_metrics.yaml
diff --git a/internal/collector/gte_pg17_metrics.yaml b/internal/collector/gte_pg17_fast_metrics.yaml
similarity index 94%
rename from internal/collector/gte_pg17_metrics.yaml
rename to internal/collector/gte_pg17_fast_metrics.yaml
index ea5d6c0fe3..688a919f5c 100644
--- a/internal/collector/gte_pg17_metrics.yaml
+++ b/internal/collector/gte_pg17_fast_metrics.yaml
@@ -71,6 +71,9 @@
         static_attributes:
           server: "localhost:5432"
 
+# NOTE: Some of the columns below can return NULL values, for which sqlqueryreceiver will warn.
+# https://github.com/open-telemetry/opentelemetry-collector-contrib/tree/main/receiver/sqlqueryreceiver#null-values
+# Those columns are retained_bytes, database, conflicting, failover, and synced and we avoid NULL by using COALESCE.
   - sql: >
       SELECT
           s.slot_name
diff --git a/internal/collector/lt_pg16_fast_metrics.yaml b/internal/collector/lt_pg16_fast_metrics.yaml
new file mode 100644
index 0000000000..8144abc144
--- /dev/null
+++ b/internal/collector/lt_pg16_fast_metrics.yaml
@@ -0,0 +1,51 @@
+# This list of queries configures an OTel SQL Query Receiver to read pgMonitor
+# metrics from Postgres.
+#
+# https://github.com/open-telemetry/opentelemetry-collector-contrib/blob/-/receiver/sqlqueryreceiver#metrics-queries
+# https://github.com/CrunchyData/pgmonitor/blob/development/sql_exporter/common/crunchy_global_collector.yml
+
+# NOTE: Some of the columns below can return NULL values, for which sqlqueryreceiver will warn.
+# https://github.com/open-telemetry/opentelemetry-collector-contrib/tree/main/receiver/sqlqueryreceiver#null-values
+# Those columns are retained_bytes and database and we avoid NULL by using COALESCE.
+  - sql: >
+      SELECT
+          s.slot_name
+          , s.active::int
+          , COALESCE(pg_wal_lsn_diff(CASE WHEN pg_is_in_recovery() THEN pg_last_wal_replay_lsn() ELSE pg_current_wal_insert_lsn() END, s.restart_lsn), 0) AS retained_bytes
+          , COALESCE(s.database, '')
+          , s.slot_type
+          , 0 AS conflicting
+          , 0 AS failover
+          , 0 AS synced
+      FROM pg_catalog.pg_replication_slots s;
+    metrics:
+      - metric_name: ccp_replication_slots_active
+        value_column: active
+        description: Active state of slot. 1 = true. 0 = false.
+        attribute_columns: ["database", "slot_name", "slot_type"]
+        static_attributes:
+          server: "localhost:5432"
+      - metric_name: ccp_replication_slots_retained_bytes
+        value_column: retained_bytes
+        description: The amount of WAL (in bytes) being retained for this slot
+        attribute_columns: ["database", "slot_name", "slot_type"]
+        static_attributes:
+          server: "localhost:5432"
+      - metric_name: ccp_replication_slots_conflicting
+        value_column: conflicting
+        description: True if this logical slot conflicted with recovery (and so is now invalidated). When this column is true, check invalidation_reason column for the conflict reason. Always NULL for physical slots.
+        attribute_columns: ["database", "slot_name", "slot_type"]
+        static_attributes:
+          server: "localhost:5432"
+      - metric_name: ccp_replication_slots_failover
+        value_column: failover
+        description: True if this is a logical slot enabled to be synced to the standbys so that logical replication can be resumed from the new primary after failover. Always false for physical slots.
+        attribute_columns: ["database", "slot_name", "slot_type"]
+        static_attributes:
+          server: "localhost:5432"
+      - metric_name: ccp_replication_slots_synced
+        value_column: synced
+        description: True if this is a logical slot that was synced from a primary server. On a hot standby, the slots with the synced column marked as true can neither be used for logical decoding nor dropped manually. The value of this column has no meaning on the primary server; the column value on the primary is default false for all slots but may (if leftover from a promoted standby) also be true.
+        attribute_columns: ["database", "slot_name", "slot_type"]
+        static_attributes:
+          server: "localhost:5432"
diff --git a/internal/collector/lt_pg16_metrics.yaml b/internal/collector/lt_pg16_slow_metrics.yaml
similarity index 71%
rename from internal/collector/lt_pg16_metrics.yaml
rename to internal/collector/lt_pg16_slow_metrics.yaml
index afa4e48228..ca9fe8a0c8 100644
--- a/internal/collector/lt_pg16_metrics.yaml
+++ b/internal/collector/lt_pg16_slow_metrics.yaml
@@ -133,46 +133,3 @@
         attribute_columns: ["dbname", "relname", "schemaname"]
         static_attributes:
           server: "localhost:5432"
-
-  - sql: >
-      SELECT
-          s.slot_name
-          , s.active::int
-          , COALESCE(pg_wal_lsn_diff(CASE WHEN pg_is_in_recovery() THEN pg_last_wal_replay_lsn() ELSE pg_current_wal_insert_lsn() END, s.restart_lsn), 0) AS retained_bytes
-          , COALESCE(s.database, '')
-          , s.slot_type
-          , 0 AS conflicting
-          , 0 AS failover
-          , 0 AS synced
-      FROM pg_catalog.pg_replication_slots s;
-    metrics:
-      - metric_name: ccp_replication_slots_active
-        value_column: active
-        description: Active state of slot. 1 = true. 0 = false.
-        attribute_columns: ["database", "slot_name", "slot_type"]
-        static_attributes:
-          server: "localhost:5432"
-      - metric_name: ccp_replication_slots_retained_bytes
-        value_column: retained_bytes
-        description: The amount of WAL (in bytes) being retained for this slot
-        attribute_columns: ["database", "slot_name", "slot_type"]
-        static_attributes:
-          server: "localhost:5432"
-      - metric_name: ccp_replication_slots_conflicting
-        value_column: conflicting
-        description: True if this logical slot conflicted with recovery (and so is now invalidated). When this column is true, check invalidation_reason column for the conflict reason. Always NULL for physical slots.
-        attribute_columns: ["database", "slot_name", "slot_type"]
-        static_attributes:
-          server: "localhost:5432"
-      - metric_name: ccp_replication_slots_failover
-        value_column: failover
-        description: True if this is a logical slot enabled to be synced to the standbys so that logical replication can be resumed from the new primary after failover. Always false for physical slots.
-        attribute_columns: ["database", "slot_name", "slot_type"]
-        static_attributes:
-          server: "localhost:5432"
-      - metric_name: ccp_replication_slots_synced
-        value_column: synced
-        description: True if this is a logical slot that was synced from a primary server. On a hot standby, the slots with the synced column marked as true can neither be used for logical decoding nor dropped manually. The value of this column has no meaning on the primary server; the column value on the primary is default false for all slots but may (if leftover from a promoted standby) also be true.
-        attribute_columns: ["database", "slot_name", "slot_type"]
-        static_attributes:
-          server: "localhost:5432"
diff --git a/internal/collector/lt_pg17_metrics.yaml b/internal/collector/lt_pg17_fast_metrics.yaml
similarity index 100%
rename from internal/collector/lt_pg17_metrics.yaml
rename to internal/collector/lt_pg17_fast_metrics.yaml
diff --git a/internal/collector/postgres_5m_metrics.yaml b/internal/collector/postgres_5m_metrics.yaml
index 95764fe3e1..dcf083c93f 100644
--- a/internal/collector/postgres_5m_metrics.yaml
+++ b/internal/collector/postgres_5m_metrics.yaml
@@ -35,120 +35,3 @@
           Function monitor.sequence_status() can provide more details if run directly on system.
         static_attributes:
           server: "localhost:5432"
-
-  - sql: >
-      SELECT s.datname AS dbname
-      , s.xact_commit
-      , s.xact_rollback
-      , s.blks_read
-      , s.blks_hit
-      , s.tup_returned
-      , s.tup_fetched
-      , s.tup_inserted
-      , s.tup_updated
-      , s.tup_deleted
-      , s.conflicts
-      , s.temp_files
-      , s.temp_bytes
-      , s.deadlocks
-      FROM pg_catalog.pg_stat_database s
-      JOIN pg_catalog.pg_database d ON d.datname = s.datname
-      WHERE d.datistemplate = false;
-    metrics:
-      - metric_name: ccp_stat_database_blks_hit 
-        value_column: blks_hit
-        description: Number of times disk blocks were found already in the buffer cache, so that a read was not necessary
-        attribute_columns: ["dbname"]
-        static_attributes:
-          server: "localhost:5432"
-      - metric_name: ccp_stat_database_blks_read  
-        value_column: blks_read
-        description: Number of disk blocks read in this database
-        attribute_columns: ["dbname"]
-        static_attributes:
-          server: "localhost:5432"
-      - metric_name: ccp_stat_database_conflicts   
-        value_column: conflicts
-        description: Number of queries canceled due to conflicts with recovery in this database
-        attribute_columns: ["dbname"]
-        static_attributes:
-          server: "localhost:5432"
-      - metric_name: ccp_stat_database_deadlocks 
-        value_column: deadlocks
-        description: Number of deadlocks detected in this database
-        attribute_columns: ["dbname"]
-        static_attributes:
-          server: "localhost:5432"
-      - metric_name: ccp_stat_database_temp_bytes
-        value_column: temp_bytes
-        description: Total amount of data written to temporary files by queries in this database
-        attribute_columns: ["dbname"]
-        static_attributes:
-          server: "localhost:5432"
-      - metric_name: ccp_stat_database_temp_files 
-        value_column: temp_files
-        description: Number of rows deleted by queries in this database
-        attribute_columns: ["dbname"]
-        static_attributes:
-          server: "localhost:5432"
-   
-      - metric_name: ccp_stat_database_tup_deleted 
-        value_column: tup_deleted
-        description: Number of rows deleted by queries in this database
-        attribute_columns: ["dbname"]
-        static_attributes:
-          server: "localhost:5432"
-   
-      - metric_name: ccp_stat_database_tup_fetched 
-        value_column: tup_fetched
-        description: Number of rows fetched by queries in this database
-        attribute_columns: ["dbname"]
-        static_attributes:
-          server: "localhost:5432"
-   
-      - metric_name: ccp_stat_database_tup_inserted 
-        value_column: tup_inserted
-        description: Number of rows inserted by queries in this database
-        attribute_columns: ["dbname"]
-        static_attributes:
-          server: "localhost:5432"
-   
-      - metric_name: ccp_stat_database_tup_returned 
-        value_column: tup_returned
-        description: Number of rows returned by queries in this database
-        attribute_columns: ["dbname"]
-        static_attributes:
-          server: "localhost:5432"
-   
-      - metric_name: ccp_stat_database_tup_updated 
-        value_column: tup_updated
-        description: Number of rows updated by queries in this database
-        attribute_columns: ["dbname"]
-        static_attributes:
-          server: "localhost:5432"
-   
-      - metric_name: ccp_stat_database_xact_commit 
-        value_column: xact_commit
-        description: Number of transactions in this database that have been committed
-        attribute_columns: ["dbname"]
-        static_attributes:
-          server: "localhost:5432"
-   
-      - metric_name: ccp_stat_database_xact_rollback 
-        value_column: xact_rollback
-        description: Number of transactions in this database that have been rolled back
-        attribute_columns: ["dbname"]
-        static_attributes:
-          server: "localhost:5432"
-
-  - sql: SELECT monitor.pg_hba_checksum() AS status;
-    metrics:
-      - metric_name: ccp_pg_hba_checksum 
-        value_column: status
-        description: |
-          Value of checksum monitoring status for pg_catalog.pg_hba_file_rules (pg_hba.conf).
-          0 = valid config. 1 = settings changed. 
-          Settings history is available for review in the table `monitor.pg_hba_checksum`.
-          To reset current config to valid after alert, run monitor.pg_hba_checksum_set_valid(). Note this will clear the history table.
-        static_attributes:
-          server: "localhost:5432"
diff --git a/internal/collector/postgres_5s_metrics.yaml b/internal/collector/postgres_5s_metrics.yaml
index 82ab10ef3c..6d92dfa75a 100644
--- a/internal/collector/postgres_5s_metrics.yaml
+++ b/internal/collector/postgres_5s_metrics.yaml
@@ -957,3 +957,108 @@
         attribute_columns: ["repo"]
         static_attributes:
           server: "localhost:5432"
+
+  - sql: >
+      SELECT s.datname AS dbname
+      , s.xact_commit
+      , s.xact_rollback
+      , s.blks_read
+      , s.blks_hit
+      , s.tup_returned
+      , s.tup_fetched
+      , s.tup_inserted
+      , s.tup_updated
+      , s.tup_deleted
+      , s.conflicts
+      , s.temp_files
+      , s.temp_bytes
+      , s.deadlocks
+      FROM pg_catalog.pg_stat_database s
+      JOIN pg_catalog.pg_database d ON d.datname = s.datname
+      WHERE d.datistemplate = false;
+    metrics:
+      - metric_name: ccp_stat_database_blks_hit 
+        value_column: blks_hit
+        description: Number of times disk blocks were found already in the buffer cache, so that a read was not necessary
+        attribute_columns: ["dbname"]
+        static_attributes:
+          server: "localhost:5432"
+      - metric_name: ccp_stat_database_blks_read  
+        value_column: blks_read
+        description: Number of disk blocks read in this database
+        attribute_columns: ["dbname"]
+        static_attributes:
+          server: "localhost:5432"
+      - metric_name: ccp_stat_database_conflicts   
+        value_column: conflicts
+        description: Number of queries canceled due to conflicts with recovery in this database
+        attribute_columns: ["dbname"]
+        static_attributes:
+          server: "localhost:5432"
+      - metric_name: ccp_stat_database_deadlocks 
+        value_column: deadlocks
+        description: Number of deadlocks detected in this database
+        attribute_columns: ["dbname"]
+        static_attributes:
+          server: "localhost:5432"
+      - metric_name: ccp_stat_database_temp_bytes
+        value_column: temp_bytes
+        description: Total amount of data written to temporary files by queries in this database
+        attribute_columns: ["dbname"]
+        static_attributes:
+          server: "localhost:5432"
+      - metric_name: ccp_stat_database_temp_files 
+        value_column: temp_files
+        description: Number of rows deleted by queries in this database
+        attribute_columns: ["dbname"]
+        static_attributes:
+          server: "localhost:5432"
+   
+      - metric_name: ccp_stat_database_tup_deleted 
+        value_column: tup_deleted
+        description: Number of rows deleted by queries in this database
+        attribute_columns: ["dbname"]
+        static_attributes:
+          server: "localhost:5432"
+   
+      - metric_name: ccp_stat_database_tup_fetched 
+        value_column: tup_fetched
+        description: Number of rows fetched by queries in this database
+        attribute_columns: ["dbname"]
+        static_attributes:
+          server: "localhost:5432"
+   
+      - metric_name: ccp_stat_database_tup_inserted 
+        value_column: tup_inserted
+        description: Number of rows inserted by queries in this database
+        attribute_columns: ["dbname"]
+        static_attributes:
+          server: "localhost:5432"
+   
+      - metric_name: ccp_stat_database_tup_returned 
+        value_column: tup_returned
+        description: Number of rows returned by queries in this database
+        attribute_columns: ["dbname"]
+        static_attributes:
+          server: "localhost:5432"
+   
+      - metric_name: ccp_stat_database_tup_updated 
+        value_column: tup_updated
+        description: Number of rows updated by queries in this database
+        attribute_columns: ["dbname"]
+        static_attributes:
+          server: "localhost:5432"
+   
+      - metric_name: ccp_stat_database_xact_commit 
+        value_column: xact_commit
+        description: Number of transactions in this database that have been committed
+        attribute_columns: ["dbname"]
+        static_attributes:
+          server: "localhost:5432"
+   
+      - metric_name: ccp_stat_database_xact_rollback 
+        value_column: xact_rollback
+        description: Number of transactions in this database that have been rolled back
+        attribute_columns: ["dbname"]
+        static_attributes:
+          server: "localhost:5432"
diff --git a/internal/collector/postgres_metrics.go b/internal/collector/postgres_metrics.go
index f3aadb0142..098d1ff2be 100644
--- a/internal/collector/postgres_metrics.go
+++ b/internal/collector/postgres_metrics.go
@@ -24,20 +24,23 @@ var fiveSecondMetrics json.RawMessage
 //go:embed "generated/postgres_5m_metrics.json"
 var fiveMinuteMetrics json.RawMessage
 
-//go:embed "generated/gte_pg17_metrics.json"
-var gtePG17 json.RawMessage
+//go:embed "generated/gte_pg17_fast_metrics.json"
+var gtePG17Fast json.RawMessage
 
-//go:embed "generated/lt_pg17_metrics.json"
-var ltPG17 json.RawMessage
+//go:embed "generated/lt_pg17_fast_metrics.json"
+var ltPG17Fast json.RawMessage
 
-//go:embed "generated/eq_pg16_metrics.json"
-var eqPG16 json.RawMessage
+//go:embed "generated/eq_pg16_fast_metrics.json"
+var eqPG16Fast json.RawMessage
 
-//go:embed "generated/gte_pg16_metrics.json"
-var gtePG16 json.RawMessage
+//go:embed "generated/gte_pg16_slow_metrics.json"
+var gtePG16Slow json.RawMessage
 
-//go:embed "generated/lt_pg16_metrics.json"
-var ltPG16 json.RawMessage
+//go:embed "generated/lt_pg16_fast_metrics.json"
+var ltPG16Fast json.RawMessage
+
+//go:embed "generated/lt_pg16_slow_metrics.json"
+var ltPG16Slow json.RawMessage
 
 type queryMetrics struct {
 	Metrics []*metric `json:"metrics"`
@@ -70,28 +73,38 @@ func EnablePostgresMetrics(ctx context.Context, inCluster *v1beta1.PostgresClust
 		fiveMinuteMetricsClone := slices.Clone(fiveMinuteMetrics)
 
 		if inCluster.Spec.PostgresVersion >= 17 {
-			fiveSecondMetricsClone, err = appendToJSONArray(fiveSecondMetricsClone, gtePG17)
+			fiveSecondMetricsClone, err = appendToJSONArray(fiveSecondMetricsClone, gtePG17Fast)
+			if err != nil {
+				log.Error(err, "error compiling metrics for postgres 17 and greater")
+			}
 		} else {
-			fiveSecondMetricsClone, err = appendToJSONArray(fiveSecondMetricsClone, ltPG17)
-		}
-		if err != nil {
-			log.Error(err, "error compiling postgres metrics")
+			fiveSecondMetricsClone, err = appendToJSONArray(fiveSecondMetricsClone, ltPG17Fast)
+			if err != nil {
+				log.Error(err, "error compiling metrics for postgres versions less than 17")
+			}
 		}
 
 		if inCluster.Spec.PostgresVersion == 16 {
-			fiveSecondMetricsClone, err = appendToJSONArray(fiveSecondMetricsClone, eqPG16)
+			fiveSecondMetricsClone, err = appendToJSONArray(fiveSecondMetricsClone, eqPG16Fast)
 		}
 		if err != nil {
-			log.Error(err, "error compiling postgres metrics")
+			log.Error(err, "error compiling metrics for postgres 16")
 		}
 
 		if inCluster.Spec.PostgresVersion >= 16 {
-			fiveSecondMetricsClone, err = appendToJSONArray(fiveSecondMetricsClone, gtePG16)
+			fiveMinuteMetricsClone, err = appendToJSONArray(fiveMinuteMetricsClone, gtePG16Slow)
+			if err != nil {
+				log.Error(err, "error compiling metrics for postgres 16 and greater")
+			}
 		} else {
-			fiveSecondMetricsClone, err = appendToJSONArray(fiveSecondMetricsClone, ltPG16)
-		}
-		if err != nil {
-			log.Error(err, "error compiling postgres metrics")
+			fiveSecondMetricsClone, err = appendToJSONArray(fiveSecondMetricsClone, ltPG16Fast)
+			if err != nil {
+				log.Error(err, "error compiling fast metrics for postgres versions less than 16")
+			}
+			fiveMinuteMetricsClone, err = appendToJSONArray(fiveMinuteMetricsClone, ltPG16Slow)
+			if err != nil {
+				log.Error(err, "error compiling slow metrics for postgres versions less than 16")
+			}
 		}
 
 		// Remove any queries that user has specified in the spec
@@ -142,7 +155,7 @@ func EnablePostgresMetrics(ctx context.Context, inCluster *v1beta1.PostgresClust
 				MonitoringUser),
 			"collection_interval": "5s",
 			// Give Postgres time to finish setup.
-			"initial_delay": "10s",
+			"initial_delay": "15s",
 			"queries":       slices.Clone(fiveSecondMetricsClone),
 		}
 
@@ -153,7 +166,7 @@ func EnablePostgresMetrics(ctx context.Context, inCluster *v1beta1.PostgresClust
 				MonitoringUser),
 			"collection_interval": "300s",
 			// Give Postgres time to finish setup.
-			"initial_delay": "10s",
+			"initial_delay": "15s",
 			"queries":       slices.Clone(fiveMinuteMetricsClone),
 		}
 
@@ -183,7 +196,7 @@ func EnablePostgresMetrics(ctx context.Context, inCluster *v1beta1.PostgresClust
 						MonitoringUser),
 					"collection_interval": querySet.CollectionInterval,
 					// Give Postgres time to finish setup.
-					"initial_delay": "10s",
+					"initial_delay": "15s",
 					"queries": "${file:/etc/otel-collector/" +
 						querySet.Name + "/" + querySet.Queries.Key + "}",
 				}
diff --git a/internal/collector/postgres_metrics_test.go b/internal/collector/postgres_metrics_test.go
index 63a6c654f3..5aa82c50ae 100644
--- a/internal/collector/postgres_metrics_test.go
+++ b/internal/collector/postgres_metrics_test.go
@@ -17,9 +17,9 @@ func TestRemoveMetricsFromQueries(t *testing.T) {
 	err := json.Unmarshal(fiveMinuteMetrics, &fiveMinuteMetricsArr)
 	assert.NilError(t, err)
 
-	assert.Equal(t, len(fiveMinuteMetricsArr), 4)
+	assert.Equal(t, len(fiveMinuteMetricsArr), 2)
 	newArr := removeMetricsFromQueries([]string{"ccp_database_size_bytes"}, fiveMinuteMetricsArr)
-	assert.Equal(t, len(newArr), 3)
+	assert.Equal(t, len(newArr), 1)
 
 	t.Run("DeleteOneMetric", func(t *testing.T) {
 		sqlMetricsData := `[
diff --git a/testing/kuttl/e2e/otel-logging-and-metrics/04-assert-repo-host-does-not-logs.yaml b/testing/kuttl/e2e/otel-logging-and-metrics/02-assert-repo-host-does-not-logs.yaml
similarity index 100%
rename from testing/kuttl/e2e/otel-logging-and-metrics/04-assert-repo-host-does-not-logs.yaml
rename to testing/kuttl/e2e/otel-logging-and-metrics/02-assert-repo-host-does-not-logs.yaml
diff --git a/testing/kuttl/e2e/otel-logging-and-metrics/03--backup.yaml b/testing/kuttl/e2e/otel-logging-and-metrics/03--backup.yaml
new file mode 100644
index 0000000000..95daf31a6a
--- /dev/null
+++ b/testing/kuttl/e2e/otel-logging-and-metrics/03--backup.yaml
@@ -0,0 +1,6 @@
+apiVersion: kuttl.dev/v1beta1
+kind: TestStep
+apply:
+- files/03--annotate-cluster.yaml
+assert:
+- files/03-backup-completed.yaml
diff --git a/testing/kuttl/e2e/otel-logging-and-metrics/06-assert-repo-host-contains-logs.yaml b/testing/kuttl/e2e/otel-logging-and-metrics/04-assert-repo-host-contains-logs.yaml
similarity index 100%
rename from testing/kuttl/e2e/otel-logging-and-metrics/06-assert-repo-host-contains-logs.yaml
rename to testing/kuttl/e2e/otel-logging-and-metrics/04-assert-repo-host-contains-logs.yaml
diff --git a/testing/kuttl/e2e/otel-logging-and-metrics/05--backup.yaml b/testing/kuttl/e2e/otel-logging-and-metrics/05--backup.yaml
deleted file mode 100644
index 166ef662a5..0000000000
--- a/testing/kuttl/e2e/otel-logging-and-metrics/05--backup.yaml
+++ /dev/null
@@ -1,6 +0,0 @@
-apiVersion: kuttl.dev/v1beta1
-kind: TestStep
-apply:
-- files/05--annotate-cluster.yaml
-assert:
-- files/05-backup-completed.yaml
diff --git a/testing/kuttl/e2e/otel-logging-and-metrics/03-assert-pgbouncer.yaml b/testing/kuttl/e2e/otel-logging-and-metrics/05-assert-pgbouncer.yaml
similarity index 100%
rename from testing/kuttl/e2e/otel-logging-and-metrics/03-assert-pgbouncer.yaml
rename to testing/kuttl/e2e/otel-logging-and-metrics/05-assert-pgbouncer.yaml
diff --git a/testing/kuttl/e2e/otel-logging-and-metrics/02-assert-instance.yaml b/testing/kuttl/e2e/otel-logging-and-metrics/06-assert-instance.yaml
similarity index 98%
rename from testing/kuttl/e2e/otel-logging-and-metrics/02-assert-instance.yaml
rename to testing/kuttl/e2e/otel-logging-and-metrics/06-assert-instance.yaml
index 235d07e47e..096c024d89 100644
--- a/testing/kuttl/e2e/otel-logging-and-metrics/02-assert-instance.yaml
+++ b/testing/kuttl/e2e/otel-logging-and-metrics/06-assert-instance.yaml
@@ -6,7 +6,8 @@ commands:
 # and 5s queries are present, as well as patroni metrics.
 # Then, check the collector logs for patroni, pgbackrest, and postgres logs.
 # Finally, ensure the monitoring user exists and is configured.
-- script: |
+- timeout: 400
+  script: |
     retry() { bash -ceu 'printf "$1\nSleeping...\n" && sleep 5' - "$@"; }
     check_containers_ready() { bash -ceu 'echo "$1" | jq -e ".[] | select(.type==\"ContainersReady\") | .status==\"True\""' - "$@"; }
     contains() { bash -ceu '[[ "$1" == *"$2"* ]]' - "$@"; }
@@ -22,21 +23,6 @@ commands:
       exit 1
     }
 
-    scrape_metrics=$(kubectl exec "${pod}" -c collector -n "${NAMESPACE}" -- \
-      curl --insecure --silent http://localhost:9187/metrics)
-    { contains "${scrape_metrics}" 'ccp_connection_stats_active'; } || {
-      retry "5 second metric not found"
-      exit 1
-    }
-    { contains "${scrape_metrics}" 'ccp_database_size_bytes'; } || {
-      retry "5 minute metric not found"
-      exit 1
-    }
-    { contains "${scrape_metrics}" 'patroni_postgres_running'; } || {
-      retry "patroni metric not found"
-      exit 1
-    }
-
     logs=$(kubectl logs "${pod}" --namespace "${NAMESPACE}" -c collector | grep InstrumentationScope)
     { contains "${logs}" 'InstrumentationScope patroni'; } || {
       retry "patroni logs not found"
@@ -51,6 +37,21 @@ commands:
       exit 1
     }
 
+    scrape_metrics=$(kubectl exec "${pod}" -c collector -n "${NAMESPACE}" -- \
+      curl --insecure --silent http://localhost:9187/metrics)
+    { contains "${scrape_metrics}" 'ccp_connection_stats_active'; } || {
+      retry "5 second metric not found"
+      exit 1
+    }
+    { contains "${scrape_metrics}" 'patroni_postgres_running'; } || {
+      retry "patroni metric not found"
+      exit 1
+    }
+    { contains "${scrape_metrics}" 'ccp_database_size_bytes'; } || {
+      retry "5 minute metric not found"
+      exit 1
+    }
+
     kubectl exec --stdin "${pod}" --namespace "${NAMESPACE}" -c database \
       -- psql -qb --set ON_ERROR_STOP=1 --file=- <<'SQL'
       DO $$
diff --git a/testing/kuttl/e2e/otel-logging-and-metrics/files/05--annotate-cluster.yaml b/testing/kuttl/e2e/otel-logging-and-metrics/files/03--annotate-cluster.yaml
similarity index 100%
rename from testing/kuttl/e2e/otel-logging-and-metrics/files/05--annotate-cluster.yaml
rename to testing/kuttl/e2e/otel-logging-and-metrics/files/03--annotate-cluster.yaml
diff --git a/testing/kuttl/e2e/otel-logging-and-metrics/files/05-backup-completed.yaml b/testing/kuttl/e2e/otel-logging-and-metrics/files/03-backup-completed.yaml
similarity index 100%
rename from testing/kuttl/e2e/otel-logging-and-metrics/files/05-backup-completed.yaml
rename to testing/kuttl/e2e/otel-logging-and-metrics/files/03-backup-completed.yaml