@Internal public final class AIMDRateLimitingStrategy extends Object
This Strategy is used by the writer to implement rate limiting on request thoroughput to match throttled destinations.
Constructor and Description |
---|
AIMDRateLimitingStrategy(int increaseRate,
double decreaseFactor,
int rateThreshold,
int initialRate) |
public AIMDRateLimitingStrategy(int increaseRate, double decreaseFactor, int rateThreshold, int initialRate)
increaseRate
- Linear increase value of rate limit on each acknowledgement.decreaseFactor
- Exponential decrease factor of rate limit on each failure.rateThreshold
- Threshold for maximum value of rate limit, this can be enforced due to
writer or destination specific limits.initialRate
- Initial rate limit to start with.Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.