Жизненный цикл и status DataFlow

Объекты в кластере, реконсиляция и status для CRD DataFlow. Поля spec — в Справочник spec.

Ресурсы на один DataFlow

Для DataFlow с именем <name> в namespace:

Контроллер выставляет owner reference, чтобы owned-ресурсы удалялись вместе с DataFlow.

Цикл реконсиляции

DataFlowReconciler:

1. Получить DataFlow — при удалении очистить Deployment, ConfigMaps, RBAC; status Stopped.
2. Подставить секреты через SecretResolver.
3. Создать/обновить df-<name>-spec.
4. При включённом checkpoint — ConfigMap checkpoint и RBAC.
5. Создать/обновить Deployment df-<name>.
6. Отразить статус Deployment в Phase/Message DataFlow.
7. Записать status в ресурс.

flowchart TD
  A[Get DataFlow] --> B{Deleted?}
  B -->|Yes| C[Cleanup Deployment, ConfigMaps, RBAC]
  C --> D[Update Status Stopped]
  B -->|No| E[Resolve Secrets]
  E --> F[Create or Update ConfigMap]
  F --> F2{CheckpointPersistence?}
  F2 -->|Yes| F3[Create Checkpoint ConfigMap and RBAC]
  F2 -->|No| G
  F3 --> G[Create or Update Deployment]
  G --> H[Read Deployment Status]
  H --> I[Update DataFlow Status]

Поля status

kubectl get dataflow
kubectl describe dataflow <name>

См. Метрики и События Kubernetes.

См. также

• Архитектура
• DataFlowCron — объекты