james/pgmon
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 3 Wiki Activity

Remove CIDR prefix from replication id

Browse Source
This commit is contained in:
James Campbell 2025-07-03 01:13:58 -04:00
parent ebb084aa9d
commit 3c39d8aa97
Signed by: james
GPG Key ID: 2287C33A40DC906A
1 changed files with 30 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

44
sample-config/pgmon-metrics.yml
View File

@ -8,14 +8,21 @@ metrics:
0: > 0: >
SELECT datname AS dbname SELECT datname AS dbname
FROM pg_database FROM pg_database
# Note: If the user lacks sufficient privileges, these fields will be NULL.
# The WHERE clause is intended to prevent Zabbix from discovering a
# connection it cannot monitor. Ideally this would generate an error
# instead.
discover_rep: discover_rep:
type: set type: set
query: query:
0: > 0: >
SELECT client_addr || '_' || regexp_replace(application_name, '[ ,]', '_', 'g') AS repid, SELECT host(client_addr) || '_' || regexp_replace(application_name, '[ ,]', '_', 'g') AS repid,
client_addr, client_addr,
state state
FROM pg_stat_replication FROM pg_stat_replication
WHERE state IS NOT NULL
discover_slots: discover_slots:
type: set type: set
query: query:
@ -36,6 +43,7 @@ metrics:
active active
FROM pg_replication_slots FROM pg_replication_slots
## ##
# cluster-wide metrics # cluster-wide metrics
## ##
@ -85,7 +93,6 @@ metrics:
FROM pg_stat_bgwriter bg FROM pg_stat_bgwriter bg
CROSS JOIN pg_stat_checkpointer cp CROSS JOIN pg_stat_checkpointer cp
io_per_backend: io_per_backend:
type: set type: set
query: query:
@ -108,6 +115,7 @@ metrics:
FROM pg_stat_io FROM pg_stat_io
GROUP BY backend_type GROUP BY backend_type
## ##
# Per-database metrics # Per-database metrics
## ##
@ -210,14 +218,20 @@ metrics:
# FROM pg_class c # FROM pg_class c
# CROSS JOIN LATERAL pg_sequence_parameters(c.oid) AS s # CROSS JOIN LATERAL pg_sequence_parameters(c.oid) AS s
# WHERE c.relkind = 'S' # WHERE c.relkind = 'S'
100000: > 100000: SELECT COALESCE(MAX(last_value::float / max_value), 0) AS max_usage FROM pg_sequences;
SELECT COALESCE(MAX(pg_sequence_last_value(c.oid)::float / sp.maximum_value), 0) AS max_usage
FROM pg_class c
CROSS JOIN LATERAL pg_sequence_parameters(c.oid) AS sp
WHERE c.relkind = 'S'
test_args: test_args:
dbname: postgres dbname: postgres
sequence_visibility:
type: row
query:
100000: >
SELECT COUNT(*) FILTER (WHERE has_sequence_privilege(c.oid, 'SELECT,USAGE'::text)) AS readable_sequences,
COUNT(*) AS total_sequences
FROM pg_class AS c
WHERE relkind = 'S';
## ##
# Per-replication metrics # Per-replication metrics
## ##
@ -237,7 +251,7 @@ metrics:
NULL AS replay_lag, NULL AS replay_lag,
sync_state sync_state
FROM pg_stat_replication FROM pg_stat_replication
WHERE client_addr || '_' || regexp_replace(application_name, '[ ,]', '_', 'g') = %(repid)s WHERE host(client_addr) || '_' || regexp_replace(application_name, '[ ,]', '_', 'g') = %(repid)s
100000: > 100000: >
SELECT pid, usename, SELECT pid, usename,
EXTRACT(EPOCH FROM backend_start)::integer AS backend_start, EXTRACT(EPOCH FROM backend_start)::integer AS backend_start,
@ -250,7 +264,8 @@ metrics:
COALESCE(EXTRACT(EPOCH FROM flush_lag), 0)::integer AS flush_lag, COALESCE(EXTRACT(EPOCH FROM flush_lag), 0)::integer AS flush_lag,
COALESCE(EXTRACT(EPOCH FROM replay_lag), 0)::integer AS replay_lag, COALESCE(EXTRACT(EPOCH FROM replay_lag), 0)::integer AS replay_lag,
sync_state sync_state
FROM pg_stat_replication WHERE client_addr || '_' || regexp_replace(application_name, '[ ,]', '_', 'g') = %(repid)s FROM pg_stat_replication
WHERE host(client_addr) || '_' || regexp_replace(application_name, '[ ,]', '_', 'g') = %(repid)s
test_args: test_args:
repid: 127.0.0.1_test_rep repid: 127.0.0.1_test_rep
@ -264,24 +279,25 @@ metrics:
90400: > 90400: >
SELECT NULL as active_pid, SELECT NULL as active_pid,
xmin, xmin,
pg_xlog_location_diff(pg_current_xlog_location(), restart_lsn) AS restart_bytes, pg_xlog_location_diff(pg_current_xlog_location(), restart_lsn)::bigint AS restart_bytes,
NULL AS confirmed_flush_bytes NULL AS confirmed_flush_bytes
FROM pg_replication_slots WHERE slot_name = %(slot)s FROM pg_replication_slots WHERE slot_name = %(slot)s
90600: > 90600: >
SELECT active_pid, SELECT active_pid,
xmin, xmin,
pg_xlog_location_diff(pg_current_xlog_location(), restart_lsn) AS restart_bytes, pg_xlog_location_diff(pg_current_xlog_location(), restart_lsn)::bigint AS restart_bytes,
pg_xlog_location_diff(pg_current_xlog_location(), confirmed_flush_lsn) AS confirmed_flush_bytes pg_xlog_location_diff(pg_current_xlog_location(), confirmed_flush_lsn)::bigint AS confirmed_flush_bytes
FROM pg_replication_slots WHERE slot_name = %(slot)s FROM pg_replication_slots WHERE slot_name = %(slot)s
100000: > 100000: >
SELECT active_pid, SELECT active_pid,
xmin, xmin,
pg_wal_lsn_diff(pg_current_wal_lsn(), restart_lsn) AS restart_bytes, pg_wal_lsn_diff(pg_current_wal_lsn(), restart_lsn)::bigint AS restart_bytes,
pg_wal_lsn_diff(pg_current_wal_lsn(), confirmed_flush_lsn) AS confirmed_flush_bytes pg_wal_lsn_diff(pg_current_wal_lsn(), confirmed_flush_lsn)::bigint AS confirmed_flush_bytes
FROM pg_replication_slots WHERE slot_name = %(slot)s FROM pg_replication_slots WHERE slot_name = %(slot)s
test_args: test_args:
slot: test_slot slot: test_slot
## ##
# Debugging # Debugging
## ##