ddl_notifier: implement serialization and deserialization for `Schema…

…ChangeEvent` (#56089) ref #55722
pingcap · Sep 18, 2024 · 7ce6ec3 · 7ce6ec3
1 parent 8313bbc
commit 7ce6ec3
Show file tree

Hide file tree

Showing 5 changed files with 184 additions and 120 deletions.
diff --git a/pkg/ddl/notifier/BUILD.bazel b/pkg/ddl/notifier/BUILD.bazel
@@ -3,8 +3,8 @@ load("@io_bazel_rules_go//go:def.bzl", "go_library", "go_test")
 go_library(
     name = "notifier",
     srcs = [
+        "events.go",
         "publish.go",
-        "schema_change_notifier.go",
         "store.go",
     ],
     importpath = "github.com/pingcap/tidb/pkg/ddl/notifier",
@@ -13,15 +13,16 @@ go_library(
         "//pkg/ddl/session",
         "//pkg/meta/model",
         "//pkg/util/intest",
+        "@com_github_pingcap_errors//:errors",
     ],
 )
 
 go_test(
     name = "notifier_test",
     timeout = "short",
     srcs = [
+        "events_test.go",
         "publish_testkit_test.go",
-        "schema_change_notifier_test.go",
     ],
     embed = [":notifier"],
     flaky = True,