Задача
Принимать события из канала, обеспечивать быстрый доступ по ID и сохранять данные так, чтобы сервис корректно восстанавливался после рестарта.
Event-driven backendNATS Streaming
NATS Streaming
Service
Сервис обработки сообщений с надёжным хранением, HTTP API и восстановлением кэша после перезапуска.
ЯзыкGo
BrokerNATS Streaming
StoragePostgreSQL
InterfacesHTTP · CLI
Реализация
- Подписка на NATS-канал и обработка входящих сообщений
- Персистентное хранение данных в PostgreSQL
- In-memory кэш для быстрых запросов по идентификатору
- Восстановление кэша из базы при запуске
- HTTP API и CLI для получения данных
Следующий кейсАТОМХАК →