Package org.apache.hadoop.hbase.quotas

Class TestRateLimiter

java.lang.Object

org.apache.hadoop.hbase.quotas.TestRateLimiter

public class TestRateLimiter
extends Object

Verify the behaviour of the Rate Limiter.

Field Summary

Fields

Modifier and Type	Field	Description
static final HBaseClassTestRule	CLASS_RULE

Constructor Summary

Constructors

Constructor	Description
TestRateLimiter()

Method Summary

Modifier and Type	Method	Description
void	itRunsFullWithPartialRefillInterval()
void	itRunsPartialRefillIntervals()
void	itRunsRepeatedPartialRefillIntervals()
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()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

Constructor Details

TestRateLimiter

public TestRateLimiter()

Method Details

testWaitIntervalTimeUnitSeconds

public void testWaitIntervalTimeUnitSeconds()

testWaitIntervalTimeUnitMinutes

public void testWaitIntervalTimeUnitMinutes()

testWaitIntervalTimeUnitHours

public void testWaitIntervalTimeUnitHours()

testWaitIntervalTimeUnitDays

public void testWaitIntervalTimeUnitDays()

testWaitInterval

private void testWaitInterval(TimeUnit timeUnit,
 long limit,
 long expectedWaitInterval)

testOverconsumptionAverageIntervalRefillStrategy

public void testOverconsumptionAverageIntervalRefillStrategy()

testOverconsumptionFixedIntervalRefillStrategy

public void testOverconsumptionFixedIntervalRefillStrategy()
                                                    throws InterruptedException

Throws:

InterruptedException

testFixedIntervalResourceAvailability

public void testFixedIntervalResourceAvailability()
                                           throws Exception

Throws:

Exception

testLimiterBySmallerRate

public void testLimiterBySmallerRate()
                              throws InterruptedException

Throws:

InterruptedException

testCanExecuteOfAverageIntervalRateLimiter

public void testCanExecuteOfAverageIntervalRateLimiter()
                                                throws InterruptedException

Throws:

InterruptedException

testCanExecuteOfFixedIntervalRateLimiter

public void testCanExecuteOfFixedIntervalRateLimiter()
                                              throws InterruptedException

Throws:

InterruptedException

testCanExecuteByRate

public int testCanExecuteByRate(org.apache.hadoop.hbase.quotas.RateLimiter limiter,
 int rate)

testRefillOfAverageIntervalRateLimiter

public void testRefillOfAverageIntervalRateLimiter()
                                            throws InterruptedException

Throws:

InterruptedException

testRefillOfFixedIntervalRateLimiter

public void testRefillOfFixedIntervalRateLimiter()
                                          throws InterruptedException

Throws:

InterruptedException

testUnconfiguredLimiters

public void testUnconfiguredLimiters()
                              throws InterruptedException

Throws:

InterruptedException

testExtremeLimiters

public void testExtremeLimiters()
                         throws InterruptedException

Throws:

InterruptedException

testLimiterCompensationOverflow

public void testLimiterCompensationOverflow()
                                     throws InterruptedException

Throws:

InterruptedException

itRunsFullWithPartialRefillInterval

public void itRunsFullWithPartialRefillInterval()

itRunsPartialRefillIntervals

public void itRunsPartialRefillIntervals()

itRunsRepeatedPartialRefillIntervals

public void itRunsRepeatedPartialRefillIntervals()