theasda / skalka Goto Github PK

Это модуль, который получает на вход конфиг и проверяет его на соответствие схеме. При ошибке выводит кусок конфига, в котором ошибка. Как временное(а может и нет) решение можно выводить путь до ошибочного свойства.

Он получает настройки, флаг. Он умеет выдавать путь для Queue processor, откатывать (удалять папку с промежуточным состоянием), коммитить (применять состояние на целевую директорию). При выключенном сохранении промежуточного состояния, выдает сразу целевую папку.

Читает настройки из глобального конфига, учитывает аргументы запуска и выдает настройки.

Главный модуль программы. Содержит в себе все queue processor'ы, инжектит в них logger, transaction manager, variables store и этапы. Производит сборку очередей в конструкторе. На старте запускает потоки queue процессоров. Есть функция ожидания конца выполнения всех очередей.

Хранит переменные для Queue processor и Linter. Умеет создавать переменные, возвращать их.

Выводит в консоль прогресс выполнения этапов и заданий. Возможно содержит фабрику логгеров, которые передаются в этапы для вывода stdout/stderr. Так же может отвечать за вопросы из этапов.

Читает yaml(а может и не только yaml конфиги).

Содержит в себе очередь из заданий, переменные конфига, который принимает в себя этапы, transaction manager, настройки, глобальные переменные окружения, менеджер переменных.