Versions in this module Expand all Collapse all v0 v0.14.0 Jan 29, 2024 Changes in this version + type Publisher struct + func NewPublisher(t interface{ ... }) *Publisher + func (_m *Publisher) Close() error + func (_m *Publisher) Publish(ctx context.Context, event events.Event) error + type Subscriber struct + func NewSubscriber(t interface{ ... }) *Subscriber + func (_m *Subscriber) Close() error + func (_m *Subscriber) Subscribe(ctx context.Context, handler events.EventHandler) error