memory

Nov 17, 2024

Changes in this version

+ type CommandBus struct

+ Handlers CommandMapper

+ func NewCommandBus(mapper CommandMapper) (*CommandBus, error)

+ func (b *CommandBus) Dispatch(command *commands.Command) error

+ func (b *CommandBus) Register(key commands.Key, handler commands.Handler) error

+ type CommandMapper = map[commands.Key]commands.Handler

+ type EventBus struct

+ Consumers EventMapper

+ func NewEventBus(mapper EventMapper) (*EventBus, error)

+ func (b *EventBus) Publish(event *events.Event) error

+ func (b *EventBus) Subscribe(key events.Key, consumer events.Consumer) error

+ type EventMapper = map[events.Key][]events.Consumer

+ type QueryBus struct

+ Handlers QueryMapper

+ func NewQueryBus(mapper QueryMapper) (*QueryBus, error)

+ func (b *QueryBus) Ask(query *queries.Query) (*queries.Response, error)

+ func (b *QueryBus) Register(key queries.Key, handler queries.Handler) error

+ type QueryMapper = map[queries.Key]queries.Handler