Versions in this module Expand all Collapse all v0 v0.1.0 Jul 3, 2023 Changes in this version + var ErrBusClosed = errors.New("bus is closed") + var WithContinueOnErrorBusOpt = func() busOpt + var WithHandlerTimeoutEventOpt = func(d time.Duration) eventOpt + var WithMaxConcurrencyBusOpt = func(c int64) busOpt + var WithPublishTimeoutEventOpt = func(d time.Duration) eventOpt + var WithTimeoutObserverOpt = func(d time.Duration) observerOpt + func AddObserver(o observer, opts ...observerOpt) string + func Close() + func Flush(ctx context.Context) + func New(opts ...busOpt) *bus + func On(name Stringer) *subscription + func Publish(ctx context.Context, name Stringer, data interface{}, opts ...eventOpt) error + func RegexMatcher(s string) (regexMatcher, error) + func RemoveObserver(id string) bool + func SetDefault(eb *bus) + func Wait(ctx context.Context) + func When(matchers ...Matcher) *subscription + func WildcardMatcher(s string) regexMatcher + type Errors []error + func (e Errors) Error() string + type Event struct + Data interface{} + ID string + Name Stringer + Timestamp time.Time + type Matcher interface + Match func(Stringer, interface{}) bool + String func() string + type PredicateMatcher func(Stringer, interface{}) bool + func (m PredicateMatcher) Match(name Stringer, data interface{}) bool + func (m PredicateMatcher) String() string + func ExactMatcher(thisName Stringer) PredicateMatcher + type StringMatcher string + func (m StringMatcher) Match(name Stringer, data interface{}) bool + func (m StringMatcher) String() string + type Stringer interface + String func() string