Versions in this module Expand all Collapse all v1 v1.0.1 Mar 9, 2025 Changes in this version + type Bus struct + func GetGlobalBus() *Bus + func NewBus() *Bus + func (b *Bus) Publish(ctx context.Context, event Event) []error + func (b *Bus) Subscribe(eventType string, handler Handler) + func (b *Bus) Unsubscribe(eventType string, handler Handler) + type Event struct + Payload map[string]any + Type string + type Handler func(ctx context.Context, event Event) error
Go to main page