Versions in this module Expand all Collapse all v1 v1.0.1 Sep 28, 2021 Changes in this version + type EventBus struct + func NewEventBus(url, appID string, options ...Option) (*EventBus, error) + func (b *EventBus) AddHandler(ctx context.Context, m eh.EventMatcher, h eh.EventHandler) error + func (b *EventBus) Errors() <-chan eh.EventBusError + func (b *EventBus) HandleEvent(ctx context.Context, event eh.Event) error + func (b *EventBus) HandlerType() eh.EventHandlerType + func (b *EventBus) Wait() + type Option func(*EventBus) error + func WithCodec(codec eh.EventCodec) Option + func WithNATSOptions(opts ...nats.Option) Option
Go to main page