NyaQueue

NyaQueue

Go-брокер сообщений с ML-оптимизированной балансировкой (DQN) и автоконфигурацией (TD3). Хранение через tidwall/wal, оффсеты в BadgerDB, транспорт gRPC + HTTP/2.

Запуск

Локально через Docker (поднимает брокер, producer, consumer, broker-exporter, Prometheus и Grafana):

make compose-up

Затем открыть Grafana: http://localhost:3000 (anonymous viewer, дашборд "Queue Quality" в папке NyaQueue). Prometheus: http://localhost:9091.

Остановить:

make compose-down

Локальные бинари (без Docker):

make build
./bin/broker          -config config.yaml
./bin/broker-exporter -config config.yaml
./bin/producer        -config config.yaml
./bin/consumer        -config config.yaml

Эксперименты

Прогон бенчмарков для ВКР, результат в experiments/results/:

make run-experiment

Сравнение с Apache Kafka (поднимает Kafka в отдельном профиле):

make compose-kafka
make compose-experiment

Разработка

make test
make bench
make lint
make proto

Лицензия

MIT