watermilltest

Documentation

Index

• func NewPubSub(tb TestingTB) *gochannel.GoChannel
• func RunRouter(tb TestingTB, rs ...Registerer) *message.Router
• func RunRouterWithContext(tb TestingTB, ctx context.Context, rs ...Registerer) *message.Router
• type MiddlewareRegisterer
  • func NewWaitForHandlerMiddleware(handlerName string) (MiddlewareRegisterer, <-chan struct{})
  • func (m MiddlewareRegisterer) Register(router *message.Router)
• type Registerer
• type TestingTB

Functions

func NewPubSub

func NewPubSub(tb TestingTB) *gochannel.GoChannel

func RunRouter

func RunRouter(tb TestingTB, rs ...Registerer) *message.Router

func RunRouterWithContext

func RunRouterWithContext(tb TestingTB, ctx context.Context, rs ...Registerer) *message.Router

Types

type MiddlewareRegisterer

type MiddlewareRegisterer struct {
	H message.HandlerMiddleware
}

func NewWaitForHandlerMiddleware

func NewWaitForHandlerMiddleware(handlerName string) (MiddlewareRegisterer, <-chan struct{})

func (MiddlewareRegisterer) Register

func (m MiddlewareRegisterer) Register(router *message.Router)

type Registerer

type Registerer interface {
	Register(router *message.Router)
}

type TestingTB

type TestingTB interface {
	Helper()
	Errorf(format string, args ...any)
	FailNow()
	Cleanup(f func())
}

TestingTB is a subset of the API provided by both *testing.T and *testing.B.