Как реализовать real-time analytics на Go?

Event поступают через Kafka/NATS. Worker агрегирует в Redis: INCR для счётчиков, HyperLogLog для уников, sorted sets для топов. Для time-series — ClickHouse или TimescaleDB. Go worker читает из очереди и батчит вставки. Для дашборда — WebSocket с периодическим push обновлений. Предагрегация в Redis даёт мгновенное чтение.