跳至內容

並行

並行 CRD 提供了一種簡單的方式來定義分支列表,每個分支接收傳送到並行輸入通道的相同 CloudEvent。通常,每個分支都包含一個篩選函數,用於保護分支的執行。

並行在底層建立 ChannelSubscription

使用方式

並行規格

並行的規格有三個部分

  1. branches 定義 filtersubscriber 配對的列表,每個分支一個,並且可選擇性地使用 reply 物件。對於每個分支
  2. (選用)評估 filter,當它返回事件時,執行 subscriberfiltersubscriber 都必須是 Addressable
  3. subscriber 返回的事件會傳送到分支的 reply 物件。當 reply 為空時,事件會傳送到 spec.reply 物件。
  4. (選用)channelTemplate 定義用於建立 Channel 的模板。
  5. (選用)reply 定義當分支沒有自己的 reply 物件時,每個分支的結果要傳送到哪裡。

並行狀態

並行的狀態有三個部分

  1. conditions 詳細說明並行物件的整體狀態
  2. ingressChannelStatusbranchesStatuses 傳達作為此並行一部分建立的底層 ChannelSubscription 資源的狀態。
  3. address 公開,以便可以在可以使用 Addressable 的地方使用並行。傳送到此位址會將目標指向此並行前面的 Channel (與 ingressChannelStatus 相同)。

範例

請按照程式碼範例了解如何使用並行。

我們使用分析和 Cookie 來了解網站流量。您使用我們網站的資訊會與 Google 分享以達到該目的。了解更多。