Skip to Content
DocumentationOperatorsFanOut

FanOut

Overview

The FanOut operator will send messages to multiple nodes concurrently and aggregate the responses.

Examples

Aggregate stub responses

Config

name: fanout
nodes:
  - id: start
    operator: HTTPIn
    method: GET
    routes:
      - /fanout
 
  - id: b2j
    operator: BufferToJSON
 
  - id: fanout
    operator: FanOut
 
  - id: child1
    operator: Stub
    data:
      response: "Child 1 Response"
 
  - id: child2
    operator: Stub
    data:
      response: "Child 2 Response"
 
edges:
  - { from: start, to: b2j }
  - { from: b2j, to: fanout }
  - { from: fanout, to: child1 }
  - { from: fanout, to: child2 }

Request

curl -v http://localhost:2243/fanout

Response

[
  {
    "response": "Child 2 Response"
  },
  {
    "response": "Child 1 Response"
  }
]

Configuration Reference

name

Must be 'FanOut'

Stringrequired
ClaimCheckHTTPIn