Фон
Я использую EventStore (от geteventstore.com) в проекте. Итак, я реализовал сторону записи приложения. То есть я могу читать и записывать события для данного агрегата.
Теперь я на стороне чтения и мне нужно подписаться на поток. Я использую java API, и здесь все также работает.
Теперь проблема
Поток не существует... Мне нужно создать проекцию, которая объединяет события из разных потоков в один поток для моей модели чтения.
Как создать проекцию через API? Желательно с java API, но подойдет и http API.
Подробности
Поскольку проекции являются средством для модели чтения, чтобы получить точные события, которые ей нужны, новые проекции будут создаваться по мере изменения потребностей бизнеса. Поэтому моя идея заключается в том, что служба readmodel будет проверять и потенциально создавать необходимую проекцию при запуске.
Недопустимо создавать прогнозы вручную перед запуском сервиса. Это было бы похоже на ручную миграцию базы данных sql.