Documentation
¶
Index ¶
- func AssertNoRouterHandlers(t *testing.T, router *message.Router)
- func AssertRouterHandler(t *testing.T, ...)
- func NewDummyCommandHandler(handlerName string, initErr error, handleErr error) handlers.CommandHandler
- func NewDummySubscriber() message.Subscriber
- func NewDummyTelemetryHandler(handlerName string, topic string, initErr error) handlers.TelemetryHandler
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AssertNoRouterHandlers ¶
AssertNoRouterHandlers asserts no handlers are registered in a Watermill router.
func AssertRouterHandler ¶
func AssertRouterHandler(t *testing.T, expectedHandlerName, expectedSubcribeTopic, expectedPublishTopic string, refHandler reflect.Value)
AssertRouterHandler asserts a Watermill router handler.
func NewDummyCommandHandler ¶
func NewDummyCommandHandler(handlerName string, initErr error, handleErr error) handlers.CommandHandler
NewDummyCommandHandler instantiates a new dummy command handler.
func NewDummySubscriber ¶
func NewDummySubscriber() message.Subscriber
NewDummySubscriber instantiates a new dummy Watermill subscriber.
func NewDummyTelemetryHandler ¶
func NewDummyTelemetryHandler(handlerName string, topic string, initErr error) handlers.TelemetryHandler
NewDummyTelemetryHandler instantiates a new dummy telemetry handler.
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.