Versions in this module Expand all Collapse all v1 v1.0.0 Apr 21, 2021 Changes in this version + type Bus interface + Length func() int + Subscribe func(Consumer, ...Descriptor) error + SubscribeToAll func(Consumer) error + Topics func() []Descriptor + Unregister func(...Descriptor) error + Unsubscribe func(Consumer, ...Descriptor) error + func NewBus(eventStore EventStore, logger Logger, errorQueue ErrorQueue, bufferSize int) Bus + type Category string + type Consumer interface + Drop func(Descriptor) + MatchCriteria func() Match + OnSubscribe func(Descriptor, Notification) + OnUnsubscribe func(Descriptor, Notification) + ReadMessage func() Descriptor + Signout func() + type ConsumerCollection interface + Append func(...Consumer) + Delete func(...Consumer) + Exists func(Consumer) bool + Iterator func() <-chan Consumer + Length func() int + type Descriptor interface + Name func() Category + func NewDescriptor(category Category, payload Payload, version Version) Descriptor + type Dispatcher interface + func NewDispatcher(eventStore EventStore, logger Logger, errorQueue ErrorQueue, bufferSize int) Dispatcher + type ErrorQueue interface + Report func(error) + type EventStore interface + DeleteTopic func(...Descriptor) + IsSubscribed func(Descriptor, Consumer) bool + Length func() int + Load func(UUID) (ConsumerCollection, bool) + Remove func(Descriptor, ...Consumer) bool + Store func(Descriptor, ...Consumer) bool + Topics func() []Descriptor + func NewEventStore() EventStore + type Inbox interface + Read func() Descriptor + Receive func(Descriptor) + Signout func() + func NewInbox(space uint) Inbox + type Logger interface + Log func(string) + type Match func(Descriptor) bool + type Metadata map[string]interface + type Notification func(Descriptor, Consumer) + type Payload interface + type Serializer interface + func NewSerializer() Serializer + type UUID string + func NewUUID() UUID + type Version int