Versions in this module Expand all Collapse all v0 v0.2.0 May 4, 2023 Changes in this version type Option + func WithDialer(dialer *kafka.Dialer) Option v0.1.0 May 4, 2023 Changes in this version + type EventBus struct + func NewEventBus(addressList, appID string, options ...Option) (*EventBus, error) + func (b *EventBus) AddHandler(ctx context.Context, m eh.EventMatcher, h eh.EventHandler) error + func (b *EventBus) Close() error + func (b *EventBus) Errors() <-chan error + func (b *EventBus) HandleEvent(ctx context.Context, event eh.Event) error + func (b *EventBus) HandlerType() eh.EventHandlerType + type Option func(*EventBus) error + func WithAutoCreateTopic(autoCreate bool) Option + func WithClient(client *kafka.Client) Option + func WithCodec(codec eh.EventCodec) Option + func WithStartOffset(startOffset int64) Option + func WithTopic(topic string) Option + func WithTopicPartitions(numPartitions int) Option
Go to main page