Интерфейс событий TrackDB между Saver, Tracker и Stager

Этот интерфейс не является прямым RPC между Saver и Stager. Компоненты обмениваются состоянием задачи через TrackDB и RabbitMQ:

1. Saver пишет первичное событие BUILD/NEW в imageEvents.
2. Materialized views TrackDB проецируют данные в stateEvents и imagesByNames.
3. Tracker пишет RUNNING, DONE или FAIL в imageEvents по факту состояния Kubernetes Job.
4. Tracker публикует completion-событие в RabbitMQ queue stager_queue.
5. Stager читает stager_queue, проверяет данные в TrackDB, выбирает следующую стадию и пишет NEW для неё в imageEvents.

TrackDB tables

Источник событий:

imageEvents

Рабочая проекция статусов:

stateEvents

Проекция расширенных данных образа:

imagesByNames

stateEvents содержит компактную историю состояний:

imagesByNames дополнительно хранит build context, Dockerfile path, branch, tags, architectures, entrypoints и userGID. Stager использует эти данные для принятия решения по TEST и SIGN.

Событие Saver -> TrackDB

Saver вставляет в imageEvents событие BUILD/NEW. Значимые поля:

{
  "eventStage": "BUILD",
  "eventStageState": "NEW",
  "taskId": "01JBV2S4PGNV87EGC5WKYA0RND",
  "user": "alexander",
  "stageImageName": "project/image",
  "stageImageTag": "",
  "registryName": "registry.example.org",
  "buildGitURL": "https://github.com/user/repo.git",
  "buildGitBranch": "master",
  "buildConfigPath": "/path/to/config.yaml",
  "buildDockerfilePath": "./Dockerfile",
  "buildContextPath": ".",
  "repoTags": ["latest", "1.0.0"],
  "architecture": ["amd64", "arm64"],
  "entrypoints": [["/app/altflow-tests/run"]],
  "userGID": 200
}

Событие Tracker -> Stager

Tracker дополняет контекст задачи из TrackDB и публикует в RabbitMQ queue stager_queue событие завершения или запуска стадии.

Минимально значимые поля:

{
  "taskid": "01JBV2S4PGNV87EGC5WKYA0RND",
  "eventStage": "BUILD",
  "eventStageState": "DONE",
  "user": "alexander",
  "stageImageName": "project/image",
  "stageImageTag": "",
  "registryName": "registry.example.org",
  "imageId": "",
  "errorTypeNum": 0,
  "errorMessage": ""
}

Stager обрабатывает только DONE и FAIL как управляющие состояния. NEW, RUNNING и SUSPEND подтверждаются, но не запускают следующую стадию.

Логика Stager

Список стадий задаётся конфигурацией STAGES; допустимые значения:

BUILD, TEST, SIGN, PUSH, CLEANUP

Ограничения:

При выборе следующей стадии Stager:

1. Проверяет, что для taskId + eventStage ещё нет последнего NEW.
2. Пишет новое событие в imageEvents.
3. Публикует stage-event в очередь Distributor.

Формат stage-event описан в интерфейсе Stager/Distributor.