update rate limit calculation

This commit is contained in:
Evan Jarrett
2026-02-18 22:30:15 -06:00
parent 0d00de76c6
commit 5b722b3c73
+3 -4
View File
@@ -765,10 +765,9 @@ func (gc *GarbageCollector) reconcileMissingRecords(ctx context.Context, missing
"total", len(missing))
}
// Throttle to avoid flooding the firehose (~100 records/sec)
if i < len(missing)-1 {
time.Sleep(10 * time.Millisecond)
}
// Throttle: ramp delay based on record index to avoid flooding relays
delay := max(10*time.Millisecond, time.Duration(i)*100*time.Microsecond)
time.Sleep(delay)
}
if result.RecordsReconciled > 0 {