aclow

type App struct {
	Conn      *nats.EncodedConn
	Config    map[string]interface{}
	Resources map[string]interface{}
	NodeMap   map[string]Node
	Logger    Logger
	OnError   func(address string, msg Message, err error)
	// contains filtered or unexported fields
}

type Caller = func(a string, d Message) (Message, error)

type Log struct {
	// contains filtered or unexported fields
}

type Logger struct {
	// contains filtered or unexported fields
}

type Message struct {
	Header map[string]interface{}
	Body   interface{}
}

type MockNode struct {
	Tester        *Tester
	MockedModule  string
	MockedAddress string
	Mock          func(Message) (Message, error)
}

type Node interface {
	Address() []string
	Start(app *App)
	Execute(msg Message, call Caller) (Message, error)
}

type ReplyMessage struct {
	Message
	Err error
}

type StartOptions struct {
	Local         bool
	Debug         bool
	Host          string
	Port          int
	ClusterPort   int
	ClusterRoutes []*url.URL
}

type TestResource struct {
}

type Tester struct {
	App *App
	// contains filtered or unexported fields
}

type Tuple []interface{}