From bc640b0b37e675783598d062298ec538e421b70b Mon Sep 17 00:00:00 2001 From: sneak Date: Mon, 28 Jul 2025 02:50:05 +0200 Subject: [PATCH] Reduce all handler queue sizes to 100,000 --- internal/routewatch/ashandler.go | 2 +- internal/routewatch/peerhandler.go | 2 +- internal/routewatch/peeringhandler.go | 2 +- internal/routewatch/prefixhandler.go | 2 +- internal/routewatch/routingtablehandler.go | 2 +- 5 files changed, 5 insertions(+), 5 deletions(-) diff --git a/internal/routewatch/ashandler.go b/internal/routewatch/ashandler.go index 14a3619..adaaf4a 100644 --- a/internal/routewatch/ashandler.go +++ b/internal/routewatch/ashandler.go @@ -11,7 +11,7 @@ import ( const ( // asHandlerQueueSize is the queue capacity for ASN operations - asHandlerQueueSize = 200000 + asHandlerQueueSize = 100000 // asnBatchSize is the number of ASN operations to batch together asnBatchSize = 10000 diff --git a/internal/routewatch/peerhandler.go b/internal/routewatch/peerhandler.go index 9f6d8ec..6ba0d99 100644 --- a/internal/routewatch/peerhandler.go +++ b/internal/routewatch/peerhandler.go @@ -12,7 +12,7 @@ import ( const ( // peerHandlerQueueSize is the queue capacity for peer tracking operations - peerHandlerQueueSize = 200000 + peerHandlerQueueSize = 100000 // peerBatchSize is the number of peer updates to batch together peerBatchSize = 10000 diff --git a/internal/routewatch/peeringhandler.go b/internal/routewatch/peeringhandler.go index 476e3b8..0fdec6b 100644 --- a/internal/routewatch/peeringhandler.go +++ b/internal/routewatch/peeringhandler.go @@ -12,7 +12,7 @@ import ( const ( // peeringHandlerQueueSize is the queue capacity for peering operations - peeringHandlerQueueSize = 200000 + peeringHandlerQueueSize = 100000 // minPathLengthForPeering is the minimum AS path length to extract peerings minPathLengthForPeering = 2 diff --git a/internal/routewatch/prefixhandler.go b/internal/routewatch/prefixhandler.go index be621e4..f539475 100644 --- a/internal/routewatch/prefixhandler.go +++ b/internal/routewatch/prefixhandler.go @@ -14,7 +14,7 @@ import ( const ( // prefixHandlerQueueSize is the queue capacity for prefix tracking operations - prefixHandlerQueueSize = 500000 + prefixHandlerQueueSize = 100000 // prefixBatchSize is the number of prefix updates to batch together prefixBatchSize = 25000 diff --git a/internal/routewatch/routingtablehandler.go b/internal/routewatch/routingtablehandler.go index 75b7254..9bf8b0c 100644 --- a/internal/routewatch/routingtablehandler.go +++ b/internal/routewatch/routingtablehandler.go @@ -11,7 +11,7 @@ import ( const ( // routingTableHandlerQueueSize is the queue capacity for in-memory routing table operations - routingTableHandlerQueueSize = 10000 + routingTableHandlerQueueSize = 100000 ) // RoutingTableHandler handles BGP messages and updates the in-memory routing table