Versions in this module Expand all Collapse all v0 v0.0.9 Jul 30, 2021 v0.0.8 Jul 23, 2021 Changes in this version + func Close() + func Publish(topic string, data interface{}) + func Subscribe(topic string, callback Handler) + func Unsubscribe(topics ...string) + type Bus struct + func NewBus(filters ...Filter) *Bus + func (b *Bus) Close() + func (b *Bus) Publish(topic string, data interface{}) + func (b *Bus) Subscribe(topic string, callback Handler) *Token + func (b *Bus) Unsubscribe(topics ...string) + type Event struct + Data interface{} + Type string + type Filter func(pTopic, sTopic string) bool + type Handler func(event Event) + type Logger interface + Error func(args ...interface{}) + var DefaultLogger Logger = log.New() + type Token struct + func (t *Token) Close() + func (t *Token) Done() + func (t *Token) Error() error + func (t *Token) IsClose() bool