Народ, подскажите, пожалуйста, чайнику, как сделать вот такой пайплайн:
1) есть сокет с биржи, откуда приходят данные
2) данные обрабатываются, сравниваются с предыдущими (т.е. этот этап stateful), принимается решение
3) на основе принятого решения делаются запросы к API биржи, базе данных и так далее
И все это параллельно на x10 воркеров (для разных валют, одна и та же логика, но для каждой валюты свой конфиг)
Как правильно тут сделать? Супервизор, в нем 10 дочерних супервизоров, в каждом GenStage пайплайн, который пушит события и игнорирует demand?
Можно в личку, буду счастлив, если кто-то согласится в качестве ментора поработать со мной и с этим проектом🤓