Кто каким образом решает задачу событий по истечению таймаута (прим.:

удаление предупреждения через 5 минут)? С учётом того, что перезапущенный сервер не должен забыть про событие (т.е. setTimeout втопку). Пробовал через keyspace notification в редисе, но в pub/sub прилетает только ключ, без значения, а оно мне надо

Ordered set в редисе

Можно подробнее, пожалуйста?

Score - unix time выполнения задачи Само значение - описание задачи И проверки раз в секунду из отдельного демона/нескольких демонов

Как вариант, спасибо, но всё же хотелось через pubsub, а не поллинг

если есть база то туда, со структурой expired и чекать в интервале, если протух то выполнять

Push очередь. NATS Streaming или RabbitMQ Ты публикуешь мессадж с текущей датой, и потом когда оно прилетает в консумер, сверяешь дату из меседжа и текущую, и делаешь что нужно Если время не подошло, консумер не делает ничего, и ждет ресенда от очереди 2 вариант, он лучше, но требуется кубер. Крон джоб который запускается раз в минуту чекает бд и так же свряет время из документа/строки в бд и текущее, и делает нужное действие

в варианте с очередью — если время не пришло, то сообщение опять в очередь ставится, или как?

1 это костыль

Оно там просто остается + ресендится по таймауту если не отправил ack, что ты его получил и обработал. Но это не блокирует другие меседжи в очереди. Оно будет вперемешку давать новые впервые и ресенды Поэтому я и уточнил что push очередь, pull очереди (кафка, sqs) такое не прокатит

понял, спасибо

Не сказал бы. Но то что крон с запросом в базу проще (значит лучше) факт Но менеджить кроны без кубера боль

ну это такое себе, плюс на ноде можно неумерающий процесс делать который этим будет заниматься