Merge pull request #16 from film42/gt/replay

User replay lag to measure byte lag
film42 · Nov 13, 2020 · ec4cd17 · ec4cd17
2 parents b5fb97e + 2df684a
commit ec4cd17
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git a/data_source.go b/data_source.go
@@ -229,9 +229,9 @@ FROM
 		log.Fatalln("Error getting pg_current_wal_lsn:", err)
 	}
 
-	pgLastWalLsn, err := ds.getPgLastWalReceiveLsn()
+	pgLastWalLsn, err := ds.getPgLastWalReplayLsn()
 	if err != nil {
-		log.Fatalln("Error getting pg_last_wal_lsn:", err)
+		log.Fatalln("Error getting pg_last_wal_replay_lsn:", err)
 	}
 	// Skip the byte lag checks if the last wal lsn is empty
 	if pgLastWalLsn == "" {
@@ -304,9 +304,9 @@ func (ds *pgDataSource) getPgCurrentWalLsn(role string) (string, error) {
 	}
 }
 
-func (ds *pgDataSource) getPgLastWalReceiveLsn() (string, error) {
+func (ds *pgDataSource) getPgLastWalReplayLsn() (string, error) {
 	pgLastWalLsn := null.String{}
-	err := ds.DB.Get(&pgLastWalLsn, "select pg_last_wal_receive_lsn()")
+	err := ds.DB.Get(&pgLastWalLsn, "select pg_last_wal_replay_lsn()")
 	if err != nil {
 		return "", err
 	}

diff --git a/main.go b/main.go
@@ -73,7 +73,7 @@ func main() {
 	flag.Parse()
 
 	if *versionPtr {
-		fmt.Println("1.1.2")
+		fmt.Println("1.2.0")
 		return
 	}