ref(): moved Wal2JsonChanges struct to types.go

redpanda-data · Apr 26, 2024 · f8d2cb5 · f8d2cb5
1 parent 7783f2f
commit f8d2cb5
Show file tree

Hide file tree

Showing 5 changed files with 15 additions and 65 deletions.
diff --git a/example/simple/main.go b/example/simple/main.go
@@ -4,7 +4,6 @@ import (
 	"fmt"
 	"github.com/charmbracelet/log"
 	"github.com/usedatabrew/pglogicalstream"
-	"github.com/usedatabrew/pglogicalstream/messages"
 	"gopkg.in/yaml.v3"
 	"io/ioutil"
 )
@@ -26,7 +25,7 @@ func main() {
 		panic(err)
 	}
 
-	pgStream.OnMessage(func(message messages.Wal2JsonChanges) {
+	pgStream.OnMessage(func(message pglogicalstream.Wal2JsonChanges) {
 		fmt.Println(message.Changes)
 	})
 }
diff --git a/messages/go.mod b/messages/go.mod
diff --git a/messages/go.sum b/messages/go.sum
diff --git a/messages/wal2json.go b/messages/wal2json.go
diff --git a/types.go b/types.go
@@ -1,7 +1,19 @@
 package pglogicalstream
 
 import (
-	"github.com/usedatabrew/pglogicalstream/messages"
+	"github.com/apache/arrow/go/v14/arrow"
 )
 
-type OnMessage = func(message messages.Wal2JsonChanges)
+type Wal2JsonChanges struct {
+	Lsn     string
+	Changes []Wal2JsonChange `json:"change"`
+}
+
+type Wal2JsonChange struct {
+	Kind   string       `json:"action"`
+	Schema string       `json:"schema"`
+	Table  string       `json:"table"`
+	Row    arrow.Record `json:"data"`
+}
+
+type OnMessage = func(message Wal2JsonChanges)