sneak e14c89e4f1 Implement backpressure mechanism to prevent memory exhaustion ... - Add semaphore to limit concurrent message handlers to 100 - Drop messages when at capacity instead of creating unbounded goroutines - Track and log dropped messages (every 1000 drops) - Remove nested goroutine spawning in handler loop - Add metrics for dropped messages and active handlers This prevents the memory usage from growing unboundedly when the database can't keep up with the incoming BGP message stream. Messages are dropped gracefully rather than causing OOM errors.		2025-07-27 22:51:02 +02:00
..
streamer_test.go	Initial commit: RouteWatch BGP stream monitor	2025-07-27 21:18:57 +02:00
streamer.go	Implement backpressure mechanism to prevent memory exhaustion	2025-07-27 22:51:02 +02:00