API Событий (Events)
Ordinaut может запускать задачи на основе внешних событий. API Событий является точкой входа для публикации этих событий в систему.
POST /events
Публикует событие в систему. Любые задачи, настроенные с schedule_kind
типа event
, которые соответствуют topic
, будут запущены.
Тело запроса:
Поле | Тип | Обязат. | Описание |
---|---|---|---|
topic |
string | Да | Имя/тема события. |
payload |
object | Да | Полезная нагрузка JSON, связанная с событием. |
source_agent_id |
UUID | Да | UUID агента, публикующего событие. |
Ответ (202 Accepted
):
API немедленно подтверждает получение события. Обработка происходит асинхронно.
GET /topics
Выводит список всех активных тем событий, на которые подписана хотя бы одна задача.
GET /stream/recent
Получает самые последние события из потока событий. Полезно для отладки.
DELETE /stream/cleanup
Удаляет старые события из потока Redis. Это административное действие.