Versions in this module Expand all Collapse all v0 v0.15.6 Jun 13, 2022 Changes in this version + type EventBus struct + func NewEventBus(addr, appID, clientID 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 IsFailed func(*redis.XPendingExt) bool + type Option func(*EventBus) error + func WithCodec(codec eh.EventCodec) Option + func WithFailedCheckOption(isf IsFailed) Option + func WithFailedCheckStepOption(step time.Duration) Option + func WithRedisGroupStartId(idx string) Option + func WithRedisOptions(opts *redis.Options) Option