Message format

Proxy message format

Proxy module accepts an array of components like following,

insert

[
  {
    "dataset": "Wiki",
    "outputs": ["report"],
    "pattern": "scatter",
    "to": {
      "key": key,
      "date": "latest",
      "replica": "all"
    },
    "body": values
  },
  {
    "inputs": ["report"],
    "pattern": "reduction",
    "outputs": ["summary"],
    "body": reducer
  },
  {
    "inputs": ["summary"],
    "dataset": "Wiki-report",
    "pattern": "scatter",
    "to": {
      "key": key,
      "date": "latest",
      "replica": "all"
    }
  }
]

search

[
  {
    "dataset": "Wiki",
    "outputs": ["result"],
    "pattern": "broadcast",
    "to": {
      "replica": "random"
    },
    "body": queries
  },
  {
    "inputs": ["result"],
    "outputs": ["reduced"],
    "pattern": "reduction",
    "body": reducer
  },
  {
    "inputs": ["reduced"],
    "pattern": "send",
    "to": replyTo,
    "body": finalizer
  }
]

facet_search

[
  {
    "dataset": "Wiki",
    "outputs": ["main","facet"],
    "pattern": "broadcast",
    "to": {
      "replica": "random"
    },
    "body": queries
  },
  {
    "input": "main",
    "output": "main_reduced",
    "pattern": "reduction",
    "body": reduce_main
  },
  {
    "input": "facet",
    "output": "facet_reduced",
    "pattern": "reduction",
    "body": reduce_facet
  },
  {
    "input": ["main_reduced", "facet_reduced"],
    "pattern": "send",
    "to": replyTo,
    "body": finalizer
  }
]