memory

Documentation

Index

• type CommandBus
  • func (b *CommandBus) Dispatch(command *messages.Message) error
  • func (b *CommandBus) Register(key messages.Key, handler roles.CommandHandler) error
• type EventBus
  • func (b *EventBus) Publish(event *messages.Message) error
  • func (b *EventBus) Subscribe(key messages.Key, consumer roles.EventConsumer) error
• type QueryBus
  • func (b *QueryBus) Ask(query *messages.Message) (*messages.Message, error)
  • func (b *QueryBus) Register(key messages.Key, handler roles.QueryHandler) error

Types

type CommandBus

type CommandBus struct {
	Handlers commands.Mapper
}

func (*CommandBus) Dispatch

func (b *CommandBus) Dispatch(command *messages.Message) error

func (*CommandBus) Register

func (b *CommandBus) Register(key messages.Key, handler roles.CommandHandler) error

type EventBus

type EventBus struct {
	Consumers events.Mapper
}

func (*EventBus) Publish

func (b *EventBus) Publish(event *messages.Message) error

func (*EventBus) Subscribe

func (b *EventBus) Subscribe(key messages.Key, consumer roles.EventConsumer) error

type QueryBus

type QueryBus struct {
	Handlers queries.Mapper
}

func (*QueryBus) Ask

func (b *QueryBus) Ask(query *messages.Message) (*messages.Message, error)

func (*QueryBus) Register

func (b *QueryBus) Register(key messages.Key, handler roles.QueryHandler) error