public class TestRateLimiter extends Object
| Modifier and Type | Field and Description |
|---|---|
static HBaseClassTestRule |
CLASS_RULE |
| Constructor and Description |
|---|
TestRateLimiter() |
| Modifier and Type | Method and Description |
|---|---|
int |
testCanExecuteByRate(org.apache.hadoop.hbase.quotas.RateLimiter limiter,
int rate) |
void |
testCanExecuteOfAverageIntervalRateLimiter() |
void |
testCanExecuteOfFixedIntervalRateLimiter() |
void |
testExtremeLimiters() |
void |
testFixedIntervalResourceAvailability() |
void |
testLimiterBySmallerRate() |
void |
testLimiterCompensationOverflow() |
void |
testOverconsumptionAverageIntervalRefillStrategy() |
void |
testOverconsumptionFixedIntervalRefillStrategy() |
void |
testRefillOfAverageIntervalRateLimiter() |
void |
testRefillOfFixedIntervalRateLimiter() |
void |
testUnconfiguredLimiters() |
private void |
testWaitInterval(TimeUnit timeUnit,
long limit,
long expectedWaitInterval) |
void |
testWaitIntervalTimeUnitDays() |
void |
testWaitIntervalTimeUnitHours() |
void |
testWaitIntervalTimeUnitMinutes() |
void |
testWaitIntervalTimeUnitSeconds() |
public static final HBaseClassTestRule CLASS_RULE
public TestRateLimiter()
public void testWaitIntervalTimeUnitSeconds()
public void testWaitIntervalTimeUnitMinutes()
public void testWaitIntervalTimeUnitHours()
public void testWaitIntervalTimeUnitDays()
private void testWaitInterval(TimeUnit timeUnit, long limit, long expectedWaitInterval)
public void testOverconsumptionAverageIntervalRefillStrategy()
public void testOverconsumptionFixedIntervalRefillStrategy() throws InterruptedException
InterruptedExceptionpublic void testFixedIntervalResourceAvailability() throws Exception
Exceptionpublic void testLimiterBySmallerRate() throws InterruptedException
InterruptedExceptionpublic void testCanExecuteOfAverageIntervalRateLimiter() throws InterruptedException
InterruptedExceptionpublic void testCanExecuteOfFixedIntervalRateLimiter() throws InterruptedException
InterruptedExceptionpublic int testCanExecuteByRate(org.apache.hadoop.hbase.quotas.RateLimiter limiter, int rate)
public void testRefillOfAverageIntervalRateLimiter() throws InterruptedException
InterruptedExceptionpublic void testRefillOfFixedIntervalRateLimiter() throws InterruptedException
InterruptedExceptionpublic void testUnconfiguredLimiters() throws InterruptedException
InterruptedExceptionpublic void testExtremeLimiters() throws InterruptedException
InterruptedExceptionpublic void testLimiterCompensationOverflow() throws InterruptedException
InterruptedExceptionCopyright © 2007–2020 The Apache Software Foundation. All rights reserved.