Versions in this module Expand all Collapse all v1 v1.0.0 Apr 6, 2021 Changes in this version + func Body(r Message, err error) interface + func BodyAsBool(r Message, err error) bool + func BodyAsFloat64(r Message, err error) float64 + func BodyAsInt64(r Message, err error) int64 + func BodyAsString(r Message, err error) string + func GenerateTests(src string, dest string) + type App struct + Config map[string]interface{} + Conn *nats.EncodedConn + Logger Logger + NodeMap map[string]Node + OnError func(address string, msg Message, err error) + Resources map[string]interface{} + func (a *App) Call(address string, msg Message) (r Message, err error) + func (a *App) Publish(address string, msg Message) + func (a *App) RegisterModule(moduleName string, nodes []Node) + func (a *App) Start(opt StartOptions) + func (a *App) Wait() + type Caller = func(a string, d Message) (Message, error) + type Log struct + type Logger struct + type Message struct + Body interface{} + Header map[string]interface{} + type MockNode struct + Mock func(Message) (Message, error) + MockedAddress string + MockedModule string + Tester *Tester + func (m *MockNode) Address() []string + func (m *MockNode) Execute(msg Message, call Caller) (Message, error) + func (m *MockNode) Start(app *App) + type Node interface + Address func() []string + Execute func(msg Message, call Caller) (Message, error) + Start func(app *App) + type ReplyMessage struct + Err error + type StartOptions struct + ClusterPort int + ClusterRoutes []*url.URL + Debug bool + Host string + Local bool + Port int + type TestResource struct + type Tester struct + App *App + func (t *Tester) Assert(assertFunc func(Message, error)) + func (t *Tester) Mock(module string, address string, mock func(Message) (Message, error)) + func (t *Tester) Run(msg Message, testing *testing.T) + func (t *Tester) Test(module string, node Node) + type Tuple []interface
Go to main page