memory

Documentation

Index

• type CommandBus
  • 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
• type EventBus
  • 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
• type QueryBus
  • 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

Types

type CommandBus

type CommandBus struct {
	Handlers CommandMapper
}

func NewCommandBus

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

func (*CommandBus) Dispatch

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

func (*CommandBus) Register

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

type CommandMapper

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

type EventBus

type EventBus struct {
	Consumers EventMapper
}

func NewEventBus

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

func (*EventBus) Publish

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

func (*EventBus) Subscribe

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

type EventMapper

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

type QueryBus

type QueryBus struct {
	Handlers QueryMapper
}

func NewQueryBus

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

func (*QueryBus) Ask

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

func (*QueryBus) Register

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

type QueryMapper

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