| DoWhile |
do while 可以在循环中执行一组任务，直到条件不再满足
例如：${workflow.input.loopCount} 为循环遍历条件表达式
|
| Dynamic |
Wait task
|
| DynamicFork |
|
| DynamicForkInput |
|
| Event |
Task to publish Events to external queuing systems like SQS, NATS, AMQP etc.
|
| For |
for 循环遍历表达式: ${workflow.input.elements}
循环体获取元素: ${eachNameRef.output.element}
循环体获取索引下标: ${eachNameRef.output.index}
|
| ForkFor |
示例数据:elements: [A,B,C]
遍历数组原数，并行调用任务
|
| ForkJoin |
ForkJoin task 数据定义示例：
|
| Http |
Wait task
|
| Http.Input |
|
| Javascript |
JQ Transformation task See https://stedolan.github.io/jq/ for how to form the queries to parse
JSON payloads
|
| Join |
|
| JQ |
JQ Transformation task See https://stedolan.github.io/jq/ for how to form the queries to parse
JSON payloads
|
| KafkaEvent |
kafka 事件包装器
|
| SetVariable |
|
| SubWorkflow |
|
| Switch |
+----------------------+
| switch (expression) |
+----------------------+
|
v
+----------------------+
| case 张三 |
+----------------------+
|
v
+----------------------+
| do something task |
+----------------------+
|
v
+----------------------+
| default: |
+----------------------+
|
v
+----------------------+
| do something task |
+----------------------+
|
| Task<T> |
Workflow Task
|
| TaskRegistry |
|
| Terminate |
|
| Wait |
Wait task
|
| WorkTask |
Workflow task executed by a worker
自定义工作节点
|