prometheus/postgres_exporter
1
0
Fork 0
mirror of https://github.com/prometheus-community/postgres_exporter.git synced 2025-08-09 15:42:47 +03:00
Code Activity

Fixed replication pgReplicationSlotQuery - now it's working correctly for replica and primary (#825)

Browse Source 
Signed-off-by: Vadim Voitenko <vadim.voitenko@exness.com>
Co-authored-by: Vadim Voitenko <vadim.voitenko@exness.com>
This commit is contained in:
Vadim Voitenko
2023-06-27 16:47:33 +03:00
committed by GitHub
parent bf4e4fb6cc
commit 6a1bb59efb
1 changed files with 7 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
collector/pg_replication_slot.go
View File

@@ -66,11 +66,14 @@ var (
pgReplicationSlotQuery = `SELECT pgReplicationSlotQuery = `SELECT
slot_name, slot_name,
pg_current_wal_lsn() - '0/0' AS current_wal_lsn, CASE WHEN pg_is_in_recovery() THEN
coalesce(confirmed_flush_lsn, '0/0') - '0/0', pg_last_wal_receive_lsn() - '0/0'
ELSE
pg_current_wal_lsn() - '0/0'
END AS current_wal_lsn,
COALESCE(confirmed_flush_lsn, '0/0') - '0/0',
active active
FROM FROM pg_replication_slots;`
pg_replication_slots;`
) )
func (PGReplicationSlotCollector) Update(ctx context.Context, instance *instance, ch chan<- prometheus.Metric) error { func (PGReplicationSlotCollector) Update(ctx context.Context, instance *instance, ch chan<- prometheus.Metric) error {