Эта очередь должна быть персистентной и всегда ли она влезает

Question

Эта очередь должна быть персистентной и всегда ли она влезает

в память (учитывая, что старые сообщения никогда не удаляются)? Может действительно проще затащить кафку или акковские персистентные стримы?

#programming #russian #scala

0

31.01.2022

4 ответов

23 просмотра

Artem Sokolov

кароче есть процесс в памяти. допустим "джоба". со стейтами "создана", "проинициализирована", "запущена", "выполнена на 50%", "завершена" требуется в рандомный момент навесить произвольный обработчик на достижение определенного статуса (или группы статусов, удовлетворяющих условию), причем если статус уже был достигнут - то выполнить обработчик моментально. можно конечно хранить историю и выдавать промис который либо проверил по истории, либо подписался на обновления, но хочется поуниверсальнее, и в голове кейс как в кафке - есть лог, по которому можно читать с начала и при достижении конца продолжить читать как из обычной очереди/брокера. задача шире если нужно будет делать что-то типа ивентсорсинга когда проигрнываются ивенты по истории а потом докадываются новые

0

31.01.2022

Simon Автор вопроса

Artem Sokolov
кароче есть процесс в памяти. допустим "джоба". со...

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

0

31.01.2022

Oleg ℕižnik

Simon
Все, что я могу придумать выглядит, довольно монст...

я думаю, без порядковых номеров там никак

0

31.01.2022