feat: add event contracts

2025-02-11 15:51:29 +08:00
1 changed files with 5 additions and 0 deletions
--- a/contracts/events.go
+++ b/contracts/events.go
@@ -7,3 +7,8 @@ type EventHandler interface {
 	PublishToTopic() string
 	Handler(msg *message.Message) ([]*message.Message, error)
 }
+
+type EventPublisher interface {
+	Topic() string
+	Marshal() ([]byte, error)
+}