Tyk Streams Examples

ingest upstream SSE .json

{
  "info": {
    "title": "test",
    "version": "1.0.0"
  },
  "openapi": "3.0.3",
  "servers": [
    {
      "url": "http://localhost:8080/test/"
    }
  ],
  "x-tyk-streaming": {
    "streams": {
      "Bar": {
        "input": {
          "http_client": {
            "stream": {
              "codec": "delim:\n\n",
              "enabled": true,
              "reconnect": true
            },
            "url": "http://echo-server:8080/.sse"
          }
        },
        "output": {
          "broker": {
            "outputs": [
              {
                "http_server": {
                  "ws_path": "/barbaz"
                }
              },
              {
                "stdout": {
                  "codec": "lines"
                }
              }
            ],
            "pattern": "fan_out"
          }
        }
      },
      "Foo": {
        "input": {
          "http_server": {
            "path": "/post"
          },
          "label": "example_generator_input"
        },
        "output": {
          "http_server": {
            "ws_path": "/subscribe"
          },
          "label": "example_websocket_output"
        }
      }
    }
  },
  "security": [],
  "paths": {},
  "components": {
    "securitySchemes": {}
  },
  "x-tyk-api-gateway": {
    "info": {
      "dbId": "6728eaf607dbf10001f2b34c",
      "id": "fb930532d12c4f007131d07746598fd7",
      "orgId": "6728eac707dbf10001f2b348",
      "name": "test",
      "state": {
        "active": true,
        "internal": false
      }
    },
    "middleware": {
      "global": {
        "contextVariables": {
          "enabled": true
        },
        "trafficLogs": {
          "enabled": true
        }
      }
    },
    "server": {
      "listenPath": {
        "strip": true,
        "value": "/test/"
      }
    },
    "upstream": {
      "url": "http://httpbin.org/"
    }
  }
}