public void regulate() {
        double successRate = success.getRateAndReset();
        double failureRate = failure.getRateAndReset();
        double totalRate = successRate + failureRate;

        maybeRecord(successRate, failureRate);
        long newRate = calculateNewRate(rateLimiter.currentRate(), successRate, failureRate, totalRate);
        rateLimiter.update(newRate);
        volumeLimiter.update(newRate * WINDOW_SIZE);
    }
The maximum request size allowed by the regulator.
Any request larger than this size should be downscaled to this size.
s3stream/src/main/java/com/automq/stream/s3/operator/TrafficRegulator.java