functional.go

execution := application.NewExecution("v1_yyy", "send") // has Name, Info, Data inputs

mapper := application.NewMapper(func(req *application.Request) interface {} {
  var data eventOutput
  req.Get(&data)
  data.Info = "info"
  return data
})

// Wait for request event from v1_xxx service but filter with name=x.
// Execute send from v1_yyy with data by mapper.
app.WhenEvent("v1_xxx").Event("request").Filter("name", "x").Map(mapper).Execute(execution)

type eventOutput struct {
  Name string
  Info string
  Data interface{}
}