routewatch/internal/streamer
sneak 8e12c07396 Implement queue backpressure with gradual message dropping
- Add gradual message dropping based on queue utilization
- Start dropping messages at 50% queue capacity
- Drop rate increases linearly from 0% at 50% to 100% at full
- Uses random drops to maintain fair distribution
- Helps prevent queue overflow under high load
2025-07-28 22:17:00 +02:00
..
streamer_test.go Add custom logger with source location tracking and remove verbose database logs 2025-07-28 01:14:51 +02:00
streamer.go Implement queue backpressure with gradual message dropping 2025-07-28 22:17:00 +02:00