broker: add Event Context() method

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2024-05-05 16:22:06 +03:00
1 changed files with 2 additions and 0 deletions
--- a/broker/broker.go
+++ b/broker/broker.go
@@ -88,6 +88,8 @@ type BatchHandler func(Events) error

 // Event is given to a subscription handler for processing
 type Event interface {
+	// Context return context.Context for event
+	Context() context.Context
 	// Topic returns event topic
 	Topic() string
 	// Message returns broker message