Documentation
¶
Index ¶
- type Bus
- func (_m *Bus) Publish(ctx context.Context, _a1 event.Message) error
- func (_m *Bus) PublishAsync(ctx context.Context, _a1 event.Message) (<-chan error, error)
- func (_m *Bus) Subscribe(eventType string, handlerName string, handler event.Handler) error
- func (_m *Bus) Unsubscribe(eventType string) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Bus ¶
Bus is an autogenerated mock type for the Bus type
func NewBus ¶
NewBus creates a new instance of Bus. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*Bus) PublishAsync ¶
PublishAsync provides a mock function with given fields: ctx, _a1
func (*Bus) Subscribe ¶
Subscribe provides a mock function with given fields: eventType, handlerName, handler
func (*Bus) Unsubscribe ¶
Unsubscribe provides a mock function with given fields: eventType
Click to show internal directories.
Click to hide internal directories.