sneak/routewatch
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Increase batch sizes to 10000 and queue sizes to 200000, reduce timeout to 2s

Browse Source
This commit is contained in:
Jeffrey Paul 2025-07-28 02:11:05 +02:00
parent eda90d96a9
commit 8b43882526
3 changed files with 9 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
internal/routewatch/dbhandler.go
View File

@ -11,13 +11,13 @@ import (
const ( const (
// dbHandlerQueueSize is the queue capacity for database operations // dbHandlerQueueSize is the queue capacity for database operations
dbHandlerQueueSize = 50000 dbHandlerQueueSize = 200000
// batchSize is the number of operations to batch together // batchSize is the number of operations to batch together
batchSize = 32000 batchSize = 10000
// batchTimeout is the maximum time to wait before flushing a batch // batchTimeout is the maximum time to wait before flushing a batch
batchTimeout = 5 * time.Second batchTimeout = 2 * time.Second
) )
// DBHandler handles BGP messages and stores them in the database using batched operations // DBHandler handles BGP messages and stores them in the database using batched operations

6
internal/routewatch/peerhandler.go
View File

@ -12,13 +12,13 @@ import (
const ( const (
// peerHandlerQueueSize is the queue capacity for peer tracking operations // peerHandlerQueueSize is the queue capacity for peer tracking operations
peerHandlerQueueSize = 50000 peerHandlerQueueSize = 200000
// peerBatchSize is the number of peer updates to batch together // peerBatchSize is the number of peer updates to batch together
peerBatchSize = 500 peerBatchSize = 10000
// peerBatchTimeout is the maximum time to wait before flushing a batch // peerBatchTimeout is the maximum time to wait before flushing a batch
peerBatchTimeout = 5 * time.Second peerBatchTimeout = 2 * time.Second
) )
// PeerHandler tracks BGP peers from all message types using batched operations // PeerHandler tracks BGP peers from all message types using batched operations

6
internal/routewatch/prefixhandler.go
View File

@ -14,13 +14,13 @@ import (
const ( const (
// prefixHandlerQueueSize is the queue capacity for prefix tracking operations // prefixHandlerQueueSize is the queue capacity for prefix tracking operations
prefixHandlerQueueSize = 50000 prefixHandlerQueueSize = 200000
// prefixBatchSize is the number of prefix updates to batch together // prefixBatchSize is the number of prefix updates to batch together
prefixBatchSize = 2000 prefixBatchSize = 10000
// prefixBatchTimeout is the maximum time to wait before flushing a batch // prefixBatchTimeout is the maximum time to wait before flushing a batch
prefixBatchTimeout = 5 * time.Second prefixBatchTimeout = 2 * time.Second
// IP version constants // IP version constants
ipv4Version = 4 ipv4Version = 4