org.apache.hadoop.hbase.quotas

Class TestRateLimiter

java.lang.Object

org.apache.hadoop.hbase.quotas.TestRateLimiter

public class TestRateLimiter
extends java.lang.Object

Verify the behaviour of the Rate Limiter.

Constructor Summary

Constructors

Constructor and Description
TestRateLimiter()

Method Summary

Modifier and Type	Method and Description
int	testCanExecuteByRate(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()
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

Constructor Detail

TestRateLimiter

public TestRateLimiter()

Method Detail

testWaitIntervalTimeUnitSeconds

public void testWaitIntervalTimeUnitSeconds()

testWaitIntervalTimeUnitMinutes

public void testWaitIntervalTimeUnitMinutes()

testWaitIntervalTimeUnitHours

public void testWaitIntervalTimeUnitHours()

testWaitIntervalTimeUnitDays

public void testWaitIntervalTimeUnitDays()

testOverconsumptionAverageIntervalRefillStrategy

public void testOverconsumptionAverageIntervalRefillStrategy()

testOverconsumptionFixedIntervalRefillStrategy

public void testOverconsumptionFixedIntervalRefillStrategy()
                                                    throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

testFixedIntervalResourceAvailability

public void testFixedIntervalResourceAvailability()
                                           throws java.lang.Exception

Throws:

java.lang.Exception

testLimiterBySmallerRate

public void testLimiterBySmallerRate()
                              throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

testCanExecuteOfAverageIntervalRateLimiter

public void testCanExecuteOfAverageIntervalRateLimiter()
                                                throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

testCanExecuteOfFixedIntervalRateLimiter

public void testCanExecuteOfFixedIntervalRateLimiter()
                                              throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

testCanExecuteByRate

public int testCanExecuteByRate(RateLimiter limiter,
                                int rate)

testRefillOfAverageIntervalRateLimiter

public void testRefillOfAverageIntervalRateLimiter()
                                            throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

testRefillOfFixedIntervalRateLimiter

public void testRefillOfFixedIntervalRateLimiter()
                                          throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

testUnconfiguredLimiters

public void testUnconfiguredLimiters()
                              throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

testExtremeLimiters

public void testExtremeLimiters()
                         throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

testLimiterCompensationOverflow

public void testLimiterCompensationOverflow()
                                     throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException