并行¶
并行CRD提供了一种容易定义分支列表的方法,每个分支接收发送到并行入口通道的相同的CloudEvent。 通常,每个分支都由一个过滤器函数组成,以保护分支的执行。
并行创建Channel 和 Subscription 的底层。
使用¶
并行的规范¶
并行有三个部分的规格:
branches定义了filter和subscriber对的列表,每个分支一个,还有一个可选的reply对象。对于每个分支:- (可选)
filter被求值,当它返回一个事件时subscriber被执行。filterandsubscriber都必须是可寻址。 subscriber返回的事件被发送到分支reply对象。 当reply为空时,事件被发送到spec.reply对象。- (可选)
channelTemplate定义了用于创建Channels的模板。 - (可选)
reply定义了当分支没有自己的reply对象时,每个分支的结果被发送到哪里。
并行状态¶
并行状态分为三个部分:
conditions,详细描述并行对象的整体状态ingressChannelStatusandbranchesStatuses传递作为并行的一部分创建的底层ChannelandSubscription资源的状态。address被公开,以便parallel可以在可寻址的地方使用。 发送到此地址将针对这个并行的前面的“通道”(与ingressChannelStatus相同)。
例子¶
按照代码示例学习如何使用并行.