4. 控制面通信基础

Knative Eventing 的控制面由多个独立组件构成，包括 Eventing Controller、Channel Controller、Source Controller、Sugar Controller 以及 Broker/Trigger Controller。这些组件之间并不直接建立 gRPC 或 HTTP 连接来交换数据，而是统一通过 Kubernetes API Server 作为状态同步的总线。

这种架构设计借鉴了 Kubernetes 原生的“声明式状态同步”模式：所有控制面组件都是 API Server 的客户端，它们通过 Watch 机制监听自己关心的资源变化，并通过 Update/Status 子资源回写状态。整个控制面没有中心化的调度器，而是通过 API Server 的 乐观并发控制（Optimistic Concurrency Control） 和 资源版本号（ResourceVersion） 来保证状态的一致性。

4.1 状态同步的三大核心机制

控制面组件之间的状态同步依赖以下三个 Kubernetes 原语：

以 Trigger 资源的生命周期为例，控制面组件的状态同步流程如下：

1. 用户创建 Trigger：用户通过 kubectl apply 或 API 调用在 default 命名空间下创建一个 Trigger 对象，指向某个 Broker。
2. API Server 持久化：Trigger CRD 被写入 etcd，并分配 resourceVersion。
3. Broker/Trigger Controller 收到 Watch 事件：Controller 的 Informer 回调触发，发现 Trigger 的 .status 为空。
4. Controller 解析并校验：检查 Broker 是否存在、过滤器语法是否正确、订阅的 Channel 是否就绪。
5. Controller 回写 Status：通过 /status 子资源更新 Trigger 的 .status.conditions，标记为 Ready=True 或报错。
6. 其他组件感知状态变化：Channel Controller 或 Data Plane 组件通过 Watch 感知到 Trigger 已就绪，开始建立实际的投递路径。

4.2 控制面组件与 API Server 的通信架构

下图展示了 Knative Eventing 控制面组件如何围绕 Kubernetes API Server 进行状态同步：

4.3 资源版本号与乐观并发控制

当多个 Controller 同时尝试更新同一个资源的状态时，API Server 依赖 resourceVersion 进行冲突检测。每个 Controller 在更新前必须持有最新的 resourceVersion，否则更新会被拒绝（HTTP 409 Conflict）。

以 Trigger 的 Status 更新为例：

# Controller 尝试更新 Trigger 状态
PUT /apis/eventing.knative.dev/v1/namespaces/default/triggers/my-trigger/status
{
  "apiVersion": "eventing.knative.dev/v1",
  "kind": "Trigger",
  "metadata": {
    "resourceVersion": "12345"  # 必须与 etcd 中当前版本一致
  },
  "status": {
    "conditions": [
      {
        "type": "Ready",
        "status": "True",
        "lastTransitionTime": "2025-01-15T10:30:00Z"
      }
    ]
  }
}

如果另一个组件（例如 Webhook 或另一个 Controller 实例）已经将 resourceVersion 更新为 12346，则上述请求会收到 409 错误。Controller 必须重新 List 或 Watch 获取最新版本后重试。

4.4 Watch 连接的生命周期与重连机制

控制面组件通过 Informer 维护与 API Server 的长连接 Watch。Watch 连接的生命周期包含以下阶段：

Watch 连接的超时行为由 API Server 的 --watch-cache 和 --min-request-timeout 参数控制。默认情况下，API Server 会在 5-10 分钟后主动断开空闲的 Watch 连接，客户端需要实现自动重连。

4.5 状态同步的故障排查路径

当 Trigger 或其他 Eventing 资源的状态不同步时，可以按照以下路径进行排查：

1. 检查 Controller Pod 是否正常运行：kubectl get pods -n knative-eventing，确认所有 Controller 的 READY 状态为 1/1。
2. 检查 Controller 日志中的 Watch 事件：kubectl logs -n knative-eventing eventing-controller-xxx | grep -i "trigger"，确认是否收到了 Trigger 的 ADDED 事件。
3. 检查 API Server 的审计日志：确认 Trigger 的 Status 更新请求是否被 API Server 接收，以及是否有 409 Conflict 错误。
4. 检查 RBAC 权限：kubectl describe clusterrolebinding knative-eventing-controller，确认 Controller 是否有 watch、update、patch 对应 CRD 的权限。
5. 检查 etcd 健康状态：如果 etcd 性能下降，API Server 的 Watch 响应延迟会增加，导致 Controller 的 Informer 缓存滞后。