More logger fixing

dehaansa · dehaansa · commit 91b00aaa98e0 · 2025-02-13T11:41:28.000-05:00
diff --git a/cmd/postgres_exporter/main.go b/cmd/postgres_exporter/main.go
@@ -160,7 +160,7 @@ func main() {
 		}
 		landingPage, err := web.NewLandingPage(landingConfig)
 		if err != nil {
-			logger.Error("err", err)
+			logger.Error("error intitializing landingpage", "err", err)
 			os.Exit(1)
 		}
 		http.Handle("/", landingPage)
diff --git a/cmd/postgres_exporter/namespace.go b/cmd/postgres_exporter/namespace.go
@@ -232,12 +232,12 @@ func queryNamespaceMappings(ch chan<- prometheus.Metric, server *Server) map[str
 		// Serious error - a namespace disappeared
 		if err != nil {
 			namespaceErrors[namespace] = err
-			logger.Info("err", err)
+			logger.Info("missing namespace when querying", "err", err)
 		}
 		// Non-serious errors - likely version or parsing problems.
 		if len(nonFatalErrors) > 0 {
 			for _, err := range nonFatalErrors {
-				logger.Info("err", err)
+				logger.Info("issue querying namespaces", "err", err)
 			}
 		}
 
diff --git a/cmd/postgres_exporter/postgres_exporter.go b/cmd/postgres_exporter/postgres_exporter.go
@@ -678,7 +678,7 @@ func (e *Exporter) scrape(ch chan<- prometheus.Metric) {
 		if err := e.scrapeDSN(ch, dsn); err != nil {
 			errorsCount++
 
-			logger.Error("err", err)
+			logger.Error("error scraping DSN", "err", err)
 
 			if _, ok := err.(*ErrorConnectToServer); ok {
 				connectionErrorsCount++
diff --git a/collector/pg_database_wraparound.go b/collector/pg_database_wraparound.go
@@ -80,15 +80,15 @@ func (c *PGDatabaseWraparoundCollector) Update(ctx context.Context, instance *in
 		}
 
 		if !datname.Valid {
-			c.log.Debug("msg", "Skipping database with NULL name")
+			c.log.Debug("Skipping database with NULL name")
 			continue
 		}
 		if !ageDatfrozenxid.Valid {
-			c.log.Debug("msg", "Skipping stat emission with NULL age_datfrozenxid")
+			c.log.Debug("Skipping stat emission with NULL age_datfrozenxid")
 			continue
 		}
 		if !ageDatminmxid.Valid {
-			c.log.Debug("msg", "Skipping stat emission with NULL age_datminmxid")
+			c.log.Debug("Skipping stat emission with NULL age_datminmxid")
 			continue
 		}
 
diff --git a/collector/pg_stat_database.go b/collector/pg_stat_database.go
@@ -298,85 +298,85 @@ func (c *PGStatDatabaseCollector) Update(ctx context.Context, instance *instance
 		}
 
 		if !datid.Valid {
-			c.log.Debug("msg", "Skipping collecting metric because it has no datid")
+			c.log.Debug("Skipping collecting metric because it has no datid")
 			continue
 		}
 		if !datname.Valid {
-			c.log.Debug("msg", "Skipping collecting metric because it has no datname")
+			c.log.Debug("Skipping collecting metric because it has no datname")
 			continue
 		}
 		if !numBackends.Valid {
-			c.log.Debug("msg", "Skipping collecting metric because it has no numbackends")
+			c.log.Debug("Skipping collecting metric because it has no numbackends")
 			continue
 		}
 		if !xactCommit.Valid {
-			c.log.Debug("msg", "Skipping collecting metric because it has no xact_commit")
+			c.log.Debug("Skipping collecting metric because it has no xact_commit")
 			continue
 		}
 		if !xactRollback.Valid {
-			c.log.Debug("msg", "Skipping collecting metric because it has no xact_rollback")
+			c.log.Debug("Skipping collecting metric because it has no xact_rollback")
 			continue
 		}
 		if !blksRead.Valid {
-			c.log.Debug("msg", "Skipping collecting metric because it has no blks_read")
+			c.log.Debug("Skipping collecting metric because it has no blks_read")
 			continue
 		}
 		if !blksHit.Valid {
-			c.log.Debug("msg", "Skipping collecting metric because it has no blks_hit")
+			c.log.Debug("Skipping collecting metric because it has no blks_hit")
 			continue
 		}
 		if !tupReturned.Valid {
-			c.log.Debug("msg", "Skipping collecting metric because it has no tup_returned")
+			c.log.Debug("Skipping collecting metric because it has no tup_returned")
 			continue
 		}
 		if !tupFetched.Valid {
-			c.log.Debug("msg", "Skipping collecting metric because it has no tup_fetched")
+			c.log.Debug("Skipping collecting metric because it has no tup_fetched")
 			continue
 		}
 		if !tupInserted.Valid {
-			c.log.Debug("msg", "Skipping collecting metric because it has no tup_inserted")
+			c.log.Debug("Skipping collecting metric because it has no tup_inserted")
 			continue
 		}
 		if !tupUpdated.Valid {
-			c.log.Debug("msg", "Skipping collecting metric because it has no tup_updated")
+			c.log.Debug("Skipping collecting metric because it has no tup_updated")
 			continue
 		}
 		if !tupDeleted.Valid {
-			c.log.Debug("msg", "Skipping collecting metric because it has no tup_deleted")
+			c.log.Debug("Skipping collecting metric because it has no tup_deleted")
 			continue
 		}
 		if !conflicts.Valid {
-			c.log.Debug("msg", "Skipping collecting metric because it has no conflicts")
+			c.log.Debug("Skipping collecting metric because it has no conflicts")
 			continue
 		}
 		if !tempFiles.Valid {
-			c.log.Debug("msg", "Skipping collecting metric because it has no temp_files")
+			c.log.Debug("Skipping collecting metric because it has no temp_files")
 			continue
 		}
 		if !tempBytes.Valid {
-			c.log.Debug("msg", "Skipping collecting metric because it has no temp_bytes")
+			c.log.Debug("Skipping collecting metric because it has no temp_bytes")
 			continue
 		}
 		if !deadlocks.Valid {
-			c.log.Debug("msg", "Skipping collecting metric because it has no deadlocks")
+			c.log.Debug("Skipping collecting metric because it has no deadlocks")
 			continue
 		}
 		if !blkReadTime.Valid {
-			c.log.Debug("msg", "Skipping collecting metric because it has no blk_read_time")
+			c.log.Debug("Skipping collecting metric because it has no blk_read_time")
 			continue
 		}
 		if !blkWriteTime.Valid {
-			c.log.Debug("msg", "Skipping collecting metric because it has no blk_write_time")
+			c.log.Debug("Skipping collecting metric because it has no blk_write_time")
 			continue
 		}
 		if activeTimeAvail && !activeTime.Valid {
-			c.log.Debug("msg", "Skipping collecting metric because it has no active_time")
+			c.log.Debug("Skipping collecting metric because it has no active_time")
 			continue
 		}
 
 		statsResetMetric := 0.0
 		if !statsReset.Valid {
-			c.log.Debug("msg", "No metric for stats_reset, will collect 0 instead")
+			c.log.Debug("No metric for stats_reset, will collect 0 instead")
 		}
 		if statsReset.Valid {
 			statsResetMetric = float64(statsReset.Time.Unix())
diff --git a/collector/pg_stat_walreceiver.go b/collector/pg_stat_walreceiver.go
@@ -156,55 +156,55 @@ func (c *PGStatWalReceiverCollector) Update(ctx context.Context, instance *insta
 			}
 		}
 		if !upstreamHost.Valid {
-			c.log.Debug("msg", "Skipping wal receiver stats because upstream host is null")
+			c.log.Debug("Skipping wal receiver stats because upstream host is null")
 			continue
 		}
 
 		if !slotName.Valid {
-			c.log.Debug("msg", "Skipping wal receiver stats because slotname host is null")
+			c.log.Debug("Skipping wal receiver stats because slotname host is null")
 			continue
 		}
 
 		if !status.Valid {
-			c.log.Debug("msg", "Skipping wal receiver stats because status is null")
+			c.log.Debug("Skipping wal receiver stats because status is null")
 			continue
 		}
 		labels := []string{upstreamHost.String, slotName.String, status.String}
 
 		if !receiveStartLsn.Valid {
-			c.log.Debug("msg", "Skipping wal receiver stats because receive_start_lsn is null")
+			c.log.Debug("Skipping wal receiver stats because receive_start_lsn is null")
 			continue
 		}
 		if !receiveStartTli.Valid {
-			c.log.Debug("msg", "Skipping wal receiver stats because receive_start_tli is null")
+			c.log.Debug("Skipping wal receiver stats because receive_start_tli is null")
 			continue
 		}
 		if hasFlushedLSN && !flushedLsn.Valid {
-			c.log.Debug("msg", "Skipping wal receiver stats because flushed_lsn is null")
+			c.log.Debug("Skipping wal receiver stats because flushed_lsn is null")
 			continue
 		}
 		if !receivedTli.Valid {
-			c.log.Debug("msg", "Skipping wal receiver stats because received_tli is null")
+			c.log.Debug("Skipping wal receiver stats because received_tli is null")
 			continue
 		}
 		if !lastMsgSendTime.Valid {
-			c.log.Debug("msg", "Skipping wal receiver stats because last_msg_send_time is null")
+			c.log.Debug("Skipping wal receiver stats because last_msg_send_time is null")
 			continue
 		}
 		if !lastMsgReceiptTime.Valid {
-			c.log.Debug("msg", "Skipping wal receiver stats because last_msg_receipt_time is null")
+			c.log.Debug("Skipping wal receiver stats because last_msg_receipt_time is null")
 			continue
 		}
 		if !latestEndLsn.Valid {
-			c.log.Debug("msg", "Skipping wal receiver stats because latest_end_lsn is null")
+			c.log.Debug("Skipping wal receiver stats because latest_end_lsn is null")
 			continue
 		}
 		if !latestEndTime.Valid {
-			c.log.Debug("msg", "Skipping wal receiver stats because latest_end_time is null")
+			c.log.Debug("Skipping wal receiver stats because latest_end_time is null")
 			continue
 		}
 		if !upstreamNode.Valid {
-			c.log.Debug("msg", "Skipping wal receiver stats because upstream_node is null")
+			c.log.Debug("Skipping wal receiver stats because upstream_node is null")
 			continue
 		}
 		ch <- prometheus.MustNewConstMetric(
diff --git a/collector/pg_xlog_location.go b/collector/pg_xlog_location.go
@@ -58,7 +58,7 @@ func (c PGXlogLocationCollector) Update(ctx context.Context, instance *instance,
 	// https://wiki.postgresql.org/wiki/New_in_postgres_10#Renaming_of_.22xlog.22_to_.22wal.22_Globally_.28and_location.2Flsn.29
 	after10 := instance.version.Compare(semver.MustParse("10.0.0"))
 	if after10 >= 0 {
-		c.log.Warn("msg", "xlog_location collector is not available on PostgreSQL >= 10.0.0, skipping")
+		c.log.Warn("xlog_location collector is not available on PostgreSQL >= 10.0.0, skipping")
 		return nil
 	}
 

Original file line number	Diff line number	Diff line change
`@@ -160,7 +160,7 @@ func main() {`
`160`	`160`	`}`
`161`	`161`	`landingPage, err := web.NewLandingPage(landingConfig)`
`162`	`162`	`if err != nil {`
`163`		`- logger.Error("err", err)`
	`163`	`+ logger.Error("error intitializing landingpage", "err", err)`
`164`	`164`	`os.Exit(1)`
`165`	`165`	`}`
`166`	`166`	`http.Handle("/", landingPage)`
Original file line number	Diff line number	Diff line change
`@@ -232,12 +232,12 @@ func queryNamespaceMappings(ch chan<- prometheus.Metric, server *Server) map[str`
`232`	`232`	`// Serious error - a namespace disappeared`
`233`	`233`	`if err != nil {`
`234`	`234`	`namespaceErrors[namespace] = err`
`235`		`- logger.Info("err", err)`
	`235`	`+ logger.Info("missing namespace when querying", "err", err)`
`236`	`236`	`}`
`237`	`237`	`// Non-serious errors - likely version or parsing problems.`
`238`	`238`	`if len(nonFatalErrors) > 0 {`
`239`	`239`	`for _, err := range nonFatalErrors {`
`240`		`- logger.Info("err", err)`
	`240`	`+ logger.Info("issue querying namespaces", "err", err)`
`241`	`241`	`}`
`242`	`242`	`}`
`243`	`243`
Original file line number	Diff line number	Diff line change
`@@ -80,15 +80,15 @@ func (c PGDatabaseWraparoundCollector) Update(ctx context.Context, instance in`
`80`	`80`	`}`
`81`	`81`
`82`	`82`	`if !datname.Valid {`
`83`		`- c.log.Debug("msg", "Skipping database with NULL name")`
	`83`	`+ c.log.Debug("Skipping database with NULL name")`
`84`	`84`	`continue`
`85`	`85`	`}`
`86`	`86`	`if !ageDatfrozenxid.Valid {`
`87`		`- c.log.Debug("msg", "Skipping stat emission with NULL age_datfrozenxid")`
	`87`	`+ c.log.Debug("Skipping stat emission with NULL age_datfrozenxid")`
`88`	`88`	`continue`
`89`	`89`	`}`
`90`	`90`	`if !ageDatminmxid.Valid {`
`91`		`- c.log.Debug("msg", "Skipping stat emission with NULL age_datminmxid")`
	`91`	`+ c.log.Debug("Skipping stat emission with NULL age_datminmxid")`
`92`	`92`	`continue`
`93`	`93`	`}`
`94`	`94`
Original file line number	Diff line number	Diff line change
`@@ -298,85 +298,85 @@ func (c PGStatDatabaseCollector) Update(ctx context.Context, instance instance`
`298`	`298`	`}`
`299`	`299`
`300`	`300`	`if !datid.Valid {`
`301`		`- c.log.Debug("msg", "Skipping collecting metric because it has no datid")`
	`301`	`+ c.log.Debug("Skipping collecting metric because it has no datid")`
`302`	`302`	`continue`
`303`	`303`	`}`
`304`	`304`	`if !datname.Valid {`
`305`		`- c.log.Debug("msg", "Skipping collecting metric because it has no datname")`
	`305`	`+ c.log.Debug("Skipping collecting metric because it has no datname")`
`306`	`306`	`continue`
`307`	`307`	`}`
`308`	`308`	`if !numBackends.Valid {`
`309`		`- c.log.Debug("msg", "Skipping collecting metric because it has no numbackends")`
	`309`	`+ c.log.Debug("Skipping collecting metric because it has no numbackends")`
`310`	`310`	`continue`
`311`	`311`	`}`
`312`	`312`	`if !xactCommit.Valid {`
`313`		`- c.log.Debug("msg", "Skipping collecting metric because it has no xact_commit")`
	`313`	`+ c.log.Debug("Skipping collecting metric because it has no xact_commit")`
`314`	`314`	`continue`
`315`	`315`	`}`
`316`	`316`	`if !xactRollback.Valid {`
`317`		`- c.log.Debug("msg", "Skipping collecting metric because it has no xact_rollback")`
	`317`	`+ c.log.Debug("Skipping collecting metric because it has no xact_rollback")`
`318`	`318`	`continue`
`319`	`319`	`}`
`320`	`320`	`if !blksRead.Valid {`
`321`		`- c.log.Debug("msg", "Skipping collecting metric because it has no blks_read")`
	`321`	`+ c.log.Debug("Skipping collecting metric because it has no blks_read")`
`322`	`322`	`continue`
`323`	`323`	`}`
`324`	`324`	`if !blksHit.Valid {`
`325`		`- c.log.Debug("msg", "Skipping collecting metric because it has no blks_hit")`
	`325`	`+ c.log.Debug("Skipping collecting metric because it has no blks_hit")`
`326`	`326`	`continue`
`327`	`327`	`}`
`328`	`328`	`if !tupReturned.Valid {`
`329`		`- c.log.Debug("msg", "Skipping collecting metric because it has no tup_returned")`
	`329`	`+ c.log.Debug("Skipping collecting metric because it has no tup_returned")`
`330`	`330`	`continue`
`331`	`331`	`}`
`332`	`332`	`if !tupFetched.Valid {`
`333`		`- c.log.Debug("msg", "Skipping collecting metric because it has no tup_fetched")`
	`333`	`+ c.log.Debug("Skipping collecting metric because it has no tup_fetched")`
`334`	`334`	`continue`
`335`	`335`	`}`
`336`	`336`	`if !tupInserted.Valid {`
`337`		`- c.log.Debug("msg", "Skipping collecting metric because it has no tup_inserted")`
	`337`	`+ c.log.Debug("Skipping collecting metric because it has no tup_inserted")`
`338`	`338`	`continue`
`339`	`339`	`}`
`340`	`340`	`if !tupUpdated.Valid {`
`341`		`- c.log.Debug("msg", "Skipping collecting metric because it has no tup_updated")`
	`341`	`+ c.log.Debug("Skipping collecting metric because it has no tup_updated")`
`342`	`342`	`continue`
`343`	`343`	`}`
`344`	`344`	`if !tupDeleted.Valid {`
`345`		`- c.log.Debug("msg", "Skipping collecting metric because it has no tup_deleted")`
	`345`	`+ c.log.Debug("Skipping collecting metric because it has no tup_deleted")`
`346`	`346`	`continue`
`347`	`347`	`}`
`348`	`348`	`if !conflicts.Valid {`
`349`		`- c.log.Debug("msg", "Skipping collecting metric because it has no conflicts")`
	`349`	`+ c.log.Debug("Skipping collecting metric because it has no conflicts")`
`350`	`350`	`continue`
`351`	`351`	`}`
`352`	`352`	`if !tempFiles.Valid {`
`353`		`- c.log.Debug("msg", "Skipping collecting metric because it has no temp_files")`
	`353`	`+ c.log.Debug("Skipping collecting metric because it has no temp_files")`
`354`	`354`	`continue`
`355`	`355`	`}`
`356`	`356`	`if !tempBytes.Valid {`
`357`		`- c.log.Debug("msg", "Skipping collecting metric because it has no temp_bytes")`
	`357`	`+ c.log.Debug("Skipping collecting metric because it has no temp_bytes")`
`358`	`358`	`continue`
`359`	`359`	`}`
`360`	`360`	`if !deadlocks.Valid {`
`361`		`- c.log.Debug("msg", "Skipping collecting metric because it has no deadlocks")`
	`361`	`+ c.log.Debug("Skipping collecting metric because it has no deadlocks")`
`362`	`362`	`continue`
`363`	`363`	`}`
`364`	`364`	`if !blkReadTime.Valid {`
`365`		`- c.log.Debug("msg", "Skipping collecting metric because it has no blk_read_time")`
	`365`	`+ c.log.Debug("Skipping collecting metric because it has no blk_read_time")`
`366`	`366`	`continue`
`367`	`367`	`}`
`368`	`368`	`if !blkWriteTime.Valid {`
`369`		`- c.log.Debug("msg", "Skipping collecting metric because it has no blk_write_time")`
	`369`	`+ c.log.Debug("Skipping collecting metric because it has no blk_write_time")`
`370`	`370`	`continue`
`371`	`371`	`}`
`372`	`372`	`if activeTimeAvail && !activeTime.Valid {`
`373`		`- c.log.Debug("msg", "Skipping collecting metric because it has no active_time")`
	`373`	`+ c.log.Debug("Skipping collecting metric because it has no active_time")`
`374`	`374`	`continue`
`375`	`375`	`}`
`376`	`376`
`377`	`377`	`statsResetMetric := 0.0`
`378`	`378`	`if !statsReset.Valid {`
`379`		`- c.log.Debug("msg", "No metric for stats_reset, will collect 0 instead")`
	`379`	`+ c.log.Debug("No metric for stats_reset, will collect 0 instead")`
`380`	`380`	`}`
`381`	`381`	`if statsReset.Valid {`
`382`	`382`	`statsResetMetric = float64(statsReset.Time.Unix())`
Original file line number	Diff line number	Diff line change
`@@ -156,55 +156,55 @@ func (c PGStatWalReceiverCollector) Update(ctx context.Context, instance insta`
`156`	`156`	`}`
`157`	`157`	`}`
`158`	`158`	`if !upstreamHost.Valid {`
`159`		`- c.log.Debug("msg", "Skipping wal receiver stats because upstream host is null")`
	`159`	`+ c.log.Debug("Skipping wal receiver stats because upstream host is null")`
`160`	`160`	`continue`
`161`	`161`	`}`
`162`	`162`
`163`	`163`	`if !slotName.Valid {`
`164`		`- c.log.Debug("msg", "Skipping wal receiver stats because slotname host is null")`
	`164`	`+ c.log.Debug("Skipping wal receiver stats because slotname host is null")`
`165`	`165`	`continue`
`166`	`166`	`}`
`167`	`167`
`168`	`168`	`if !status.Valid {`
`169`		`- c.log.Debug("msg", "Skipping wal receiver stats because status is null")`
	`169`	`+ c.log.Debug("Skipping wal receiver stats because status is null")`
`170`	`170`	`continue`
`171`	`171`	`}`
`172`	`172`	`labels := []string{upstreamHost.String, slotName.String, status.String}`
`173`	`173`
`174`	`174`	`if !receiveStartLsn.Valid {`
`175`		`- c.log.Debug("msg", "Skipping wal receiver stats because receive_start_lsn is null")`
	`175`	`+ c.log.Debug("Skipping wal receiver stats because receive_start_lsn is null")`
`176`	`176`	`continue`
`177`	`177`	`}`
`178`	`178`	`if !receiveStartTli.Valid {`
`179`		`- c.log.Debug("msg", "Skipping wal receiver stats because receive_start_tli is null")`
	`179`	`+ c.log.Debug("Skipping wal receiver stats because receive_start_tli is null")`
`180`	`180`	`continue`
`181`	`181`	`}`
`182`	`182`	`if hasFlushedLSN && !flushedLsn.Valid {`
`183`		`- c.log.Debug("msg", "Skipping wal receiver stats because flushed_lsn is null")`
	`183`	`+ c.log.Debug("Skipping wal receiver stats because flushed_lsn is null")`
`184`	`184`	`continue`
`185`	`185`	`}`
`186`	`186`	`if !receivedTli.Valid {`
`187`		`- c.log.Debug("msg", "Skipping wal receiver stats because received_tli is null")`
	`187`	`+ c.log.Debug("Skipping wal receiver stats because received_tli is null")`
`188`	`188`	`continue`
`189`	`189`	`}`
`190`	`190`	`if !lastMsgSendTime.Valid {`
`191`		`- c.log.Debug("msg", "Skipping wal receiver stats because last_msg_send_time is null")`
	`191`	`+ c.log.Debug("Skipping wal receiver stats because last_msg_send_time is null")`
`192`	`192`	`continue`
`193`	`193`	`}`
`194`	`194`	`if !lastMsgReceiptTime.Valid {`
`195`		`- c.log.Debug("msg", "Skipping wal receiver stats because last_msg_receipt_time is null")`
	`195`	`+ c.log.Debug("Skipping wal receiver stats because last_msg_receipt_time is null")`
`196`	`196`	`continue`
`197`	`197`	`}`
`198`	`198`	`if !latestEndLsn.Valid {`
`199`		`- c.log.Debug("msg", "Skipping wal receiver stats because latest_end_lsn is null")`
	`199`	`+ c.log.Debug("Skipping wal receiver stats because latest_end_lsn is null")`
`200`	`200`	`continue`
`201`	`201`	`}`
`202`	`202`	`if !latestEndTime.Valid {`
`203`		`- c.log.Debug("msg", "Skipping wal receiver stats because latest_end_time is null")`
	`203`	`+ c.log.Debug("Skipping wal receiver stats because latest_end_time is null")`
`204`	`204`	`continue`
`205`	`205`	`}`
`206`	`206`	`if !upstreamNode.Valid {`
`207`		`- c.log.Debug("msg", "Skipping wal receiver stats because upstream_node is null")`
	`207`	`+ c.log.Debug("Skipping wal receiver stats because upstream_node is null")`
`208`	`208`	`continue`
`209`	`209`	`}`
`210`	`210`	`ch <- prometheus.MustNewConstMetric(`
Original file line number	Diff line number	Diff line change
`@@ -58,7 +58,7 @@ func (c PGXlogLocationCollector) Update(ctx context.Context, instance *instance,`
`58`	`58`	`// https://wiki.postgresql.org/wiki/New_in_postgres_10#Renaming_of_.22xlog.22_to_.22wal.22_Globally_.28and_location.2Flsn.29`
`59`	`59`	`after10 := instance.version.Compare(semver.MustParse("10.0.0"))`
`60`	`60`	`if after10 >= 0 {`
`61`		`- c.log.Warn("msg", "xlog_location collector is not available on PostgreSQL >= 10.0.0, skipping")`
	`61`	`+ c.log.Warn("xlog_location collector is not available on PostgreSQL >= 10.0.0, skipping")`
`62`	`62`	`return nil`
`63`	`63`	`}`
`64`	`64`