feat: add event contracts
This commit is contained in:
@@ -7,3 +7,8 @@ type EventHandler interface {
|
|||||||
PublishToTopic() string
|
PublishToTopic() string
|
||||||
Handler(msg *message.Message) ([]*message.Message, error)
|
Handler(msg *message.Message) ([]*message.Message, error)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
type EventPublisher interface {
|
||||||
|
Topic() string
|
||||||
|
Marshal() ([]byte, error)
|
||||||
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user