add format pg lsn

apecloud · Sep 14, 2023 · 1e3556e · 1e3556e
1 parent c19f36f
commit 1e3556e
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 2 deletions.
diff --git a/lorry/component/postgres/types.go b/lorry/component/postgres/types.go
@@ -22,6 +22,7 @@ package postgres
 import (
 	"bufio"
 	"context"
+	"fmt"
 	"strconv"
 	"strings"
 
@@ -323,8 +324,8 @@ func ParsePgLsn(str string) int64 {
 	return prefix*0x100000000 + suffix
 }
 
-func formatPgLsn(lsn int64) string {
-	return ""
+func FormatPgLsn(lsn int64) string {
+	return fmt.Sprintf("%X/%X", lsn>>32, lsn&0xFFFFFFFF)
 }
 
 func ParsePrimaryConnInfo(str string) map[string]string {

diff --git a/lorry/component/postgres/types_test.go b/lorry/component/postgres/types_test.go
@@ -170,6 +170,15 @@ func TestParsePGLsn(t *testing.T) {
 	})
 }
 
+func TestFormatPgLsn(t *testing.T) {
+	t.Run("format lsn", func(t *testing.T) {
+		lsn := int64(97500059720)
+
+		lsnStr := FormatPgLsn(lsn)
+		assert.Equal(t, "16/B374D848", lsnStr)
+	})
+}
+
 func TestParsePrimaryConnInfo(t *testing.T) {
 	t.Run("legal primary conn info str", func(t *testing.T) {
 		primaryConnInfoStr := "host=pg-pg-replication-0.pg-pg-replication-headless port=5432 user=postgres application_name=my-application"