RepoMirrors/postgres_exporter
1
0
Fork 0
mirror of https://github.com/prometheus-community/postgres_exporter synced 2025-04-01 22:48:15 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #777 from sysadmind/fix-replication-column-type

Browse Source 
Fix column type for pg_replication_slots
This commit is contained in:
Ben Kochie 2023-03-23 10:57:51 +01:00 committed by GitHub
commit dde6e6e52a
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
collector/replication_slots.go
View File

@ -69,7 +69,7 @@ func (PGReplicationSlotCollector) Update(ctx context.Context, db *sql.DB, ch cha
var slot_name string var slot_name string
var wal_lsn int64 var wal_lsn int64
var flush_lsn int64 var flush_lsn int64
var is_active int64 var is_active bool
if err := rows.Scan(&slot_name, &wal_lsn, &flush_lsn, &is_active); err != nil { if err := rows.Scan(&slot_name, &wal_lsn, &flush_lsn, &is_active); err != nil {
return err return err
} }
@ -78,7 +78,7 @@ func (PGReplicationSlotCollector) Update(ctx context.Context, db *sql.DB, ch cha
pgReplicationSlot["current_wal_lsn"], pgReplicationSlot["current_wal_lsn"],
prometheus.GaugeValue, float64(wal_lsn), slot_name, prometheus.GaugeValue, float64(wal_lsn), slot_name,
) )
if is_active == 1 { if is_active {
ch <- prometheus.MustNewConstMetric( ch <- prometheus.MustNewConstMetric(
pgReplicationSlot["confirmed_flush_lsn"], pgReplicationSlot["confirmed_flush_lsn"],
prometheus.GaugeValue, float64(flush_lsn), slot_name, prometheus.GaugeValue, float64(flush_lsn), slot_name,