并行

并行 CRD 提供了一种简单的方式来定义分支列表，每个分支都接收发送到并行入口通道的相同 CloudEvent。通常，每个分支都由一个过滤函数构成，该函数用于保护分支的执行。

并行在底层创建 Channel 和 Subscription。

用法

并行规范

并行的规范有三部分

1. branches 定义了 filter 和 subscriber 对的列表，每个分支一对，以及可选的 reply 对象。对于每个分支
2. （可选）评估 filter，当它返回一个事件时，执行 subscriber。filter 和 subscriber 都必须是 Addressable。
3. subscriber 返回的事件被发送到分支的 reply 对象。当 reply 为空时，事件被发送到 spec.reply 对象。
4. （可选）channelTemplate 定义了将用于创建 Channel 的模板。
5. （可选）reply 定义了当分支没有自己的 reply 对象时，每个分支的结果发送到哪里。

并行状态

并行的状态有三部分

1. conditions 详细说明了并行对象的整体状态
2. ingressChannelStatus 和 branchesStatuses 传达了作为此并行的一部分而创建的底层 Channel 和 Subscription 资源的状态。
3. address 被公开，以便并行可以在可寻址的地方使用。发送到此地址将针对此并行前面的 Channel（与 ingressChannelStatus 相同）。

示例

通过遵循代码示例学习如何使用并行。