Skip to content

并行

并行CRD提供了一种容易定义分支列表的方法,每个分支接收发送到并行入口通道的相同的CloudEvent。 通常,每个分支都由一个过滤器函数组成,以保护分支的执行。

并行创建ChannelSubscription 的底层。

使用

并行的规范

并行有三个部分的规格:

  1. branches定义了filtersubscriber对的列表,每个分支一个,还有一个可选的reply对象。对于每个分支:
  2. (可选)filter被求值,当它返回一个事件时subscriber被执行。filter and subscriber都必须是可寻址
  3. subscriber返回的事件被发送到分支reply对象。 当reply为空时,事件被发送到spec.reply对象。
  4. (可选)channelTemplate定义了用于创建Channels的模板。
  5. (可选)reply定义了当分支没有自己的reply对象时,每个分支的结果被发送到哪里。

并行状态

并行状态分为三个部分:

  1. conditions,详细描述并行对象的整体状态
  2. ingressChannelStatus and branchesStatuses传递作为并行的一部分创建的底层Channel and Subscription资源的状态。
  3. address被公开,以便parallel可以在可寻址的地方使用。 发送到此地址将针对这个并行的前面的“通道”(与ingressChannelStatus相同)。

例子

按照代码示例学习如何使用并行.

Back to top

We use analytics and cookies to understand site traffic. Information about your use of our site is shared with Google for that purpose. Learn more.

× OK