diff --git a/internal/routewatch/dbhandler_batched.go b/internal/routewatch/dbhandler_batched.go index a73baab..aa12b9c 100644 --- a/internal/routewatch/dbhandler_batched.go +++ b/internal/routewatch/dbhandler_batched.go @@ -14,10 +14,10 @@ const ( batchedDatabaseHandlerQueueSize = 1000 // batchSize is the number of operations to batch together - batchSize = 100 + batchSize = 500 // batchTimeout is the maximum time to wait before flushing a batch - batchTimeout = 100 * time.Millisecond + batchTimeout = 5 * time.Second ) // BatchedDatabaseHandler handles BGP messages and stores them in the database using batched operations diff --git a/internal/routewatch/peerhandler_batched.go b/internal/routewatch/peerhandler_batched.go index d0aac62..95f5450 100644 --- a/internal/routewatch/peerhandler_batched.go +++ b/internal/routewatch/peerhandler_batched.go @@ -15,10 +15,10 @@ const ( batchedPeerHandlerQueueSize = 2000 // peerBatchSize is the number of peer updates to batch together - peerBatchSize = 50 + peerBatchSize = 500 // peerBatchTimeout is the maximum time to wait before flushing a batch - peerBatchTimeout = 200 * time.Millisecond + peerBatchTimeout = 5 * time.Second ) // BatchedPeerHandler tracks BGP peers from all message types using batched operations