mini-elastic-dag.json

"dag": {
    "inputs":{
      "rpc":{
        "search":{
          "methods": ["GET"],
          "path": "/_search",
          "CORS":{}
        }
      }
    },
    "nodes":[{
      "#": "Index Node",
      "implementation": {
        "go": "server/load/load.go",
        "sandbox": "quay.io/redsift/sandbox-go-rocksdb:v5.8",
        "qos": {
          "large-storage": ["rocksdb_store:rw"],
          "long": true
        },
        "when":{
          "crontab": "0 6 * * *"
        }
      },
      "outputs":{
        "stats": {}
      }
    },{
      "#": "Query Node",
      "input":{
        "bucket": "search"
      },
      "implementation": {
        "go": "server/search/search.go",
        "sandbox": "quay.io/redsift/sandbox-go-rocksdb:v5.8",
        "qos": {
          "large-storage": ["rocksdb_store:ro"]
        }
      },
      "outputs": {
        "rpc_resp": {},
        "stats":{}
      }
    }],
    "stores":{},
    "outputs":{
      "exports":{
        "stats":{
          "key$schema": "string"
        },
        "rpc_resp": {
          "import": "_rpc"
        }
      }
    }
  }