communications

Documentation

Index

• type CommandBusMock
  • func (m *CommandBusMock) Dispatch(command *commands.Command) error
  • func (m *CommandBusMock) Register(key commands.Key, handler commands.Handler) error
• type CommandHandlerMock
  • func (m *CommandHandlerMock) Handle(command *commands.Command) error
• type EventBusMock
  • func (m *EventBusMock) Publish(event *events.Event) error
  • func (m *EventBusMock) Subscribe(key events.Key, consumers events.Consumer) error
• type EventConsumerMock
  • func (m *EventConsumerMock) On(event *events.Event) error
• type QueryBusMock
  • func (m *QueryBusMock) Ask(query *queries.Query) (*queries.Response, error)
  • func (m *QueryBusMock) Register(key queries.Key, handler queries.Handler) error
• type QueryHandlerMock
  • func (m *QueryHandlerMock) Handle(query *queries.Query) (*queries.Response, error)

Types

type CommandBusMock

type CommandBusMock struct {
	mock.Mock
}

func (*CommandBusMock) Dispatch

func (m *CommandBusMock) Dispatch(command *commands.Command) error

func (*CommandBusMock) Register

func (m *CommandBusMock) Register(key commands.Key, handler commands.Handler) error

type CommandHandlerMock

type CommandHandlerMock struct {
	mock.Mock
}

func (*CommandHandlerMock) Handle

func (m *CommandHandlerMock) Handle(command *commands.Command) error

type EventBusMock

type EventBusMock struct {
	mock.Mock
}

func (*EventBusMock) Publish

func (m *EventBusMock) Publish(event *events.Event) error

func (*EventBusMock) Subscribe

func (m *EventBusMock) Subscribe(key events.Key, consumers events.Consumer) error

type EventConsumerMock

type EventConsumerMock struct {
	mock.Mock
}

func (*EventConsumerMock) On

func (m *EventConsumerMock) On(event *events.Event) error

type QueryBusMock

type QueryBusMock struct {
	mock.Mock
}

func (*QueryBusMock) Ask

func (m *QueryBusMock) Ask(query *queries.Query) (*queries.Response, error)

func (*QueryBusMock) Register

func (m *QueryBusMock) Register(key queries.Key, handler queries.Handler) error

type QueryHandlerMock

type QueryHandlerMock struct {
	mock.Mock
}

func (*QueryHandlerMock) Handle

func (m *QueryHandlerMock) Handle(query *queries.Query) (*queries.Response, error)