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
InterruptedException
public void testFixedIntervalResourceAvailability() throws Exception
Exception
public void testLimiterBySmallerRate() throws InterruptedException
InterruptedException
public void testCanExecuteOfAverageIntervalRateLimiter() throws InterruptedException
InterruptedException
public void testCanExecuteOfFixedIntervalRateLimiter() throws InterruptedException
InterruptedException
public int testCanExecuteByRate(org.apache.hadoop.hbase.quotas.RateLimiter limiter, int rate)
public void testRefillOfAverageIntervalRateLimiter() throws InterruptedException
InterruptedException
public void testRefillOfFixedIntervalRateLimiter() throws InterruptedException
InterruptedException
public void testUnconfiguredLimiters() throws InterruptedException
InterruptedException
public void testExtremeLimiters() throws InterruptedException
InterruptedException
public void testLimiterCompensationOverflow() throws InterruptedException
InterruptedException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.