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.

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	testFixedIntervalResourceAvailability()
void	testLimiterBySmallerRate()
void	testOverconsumptionAverageIntervalRefillStrategy()
void	testOverconsumptionFixedIntervalRefillStrategy()
void	testRefillOfAverageIntervalRateLimiter()
void	testRefillOfFixedIntervalRateLimiter()
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 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(RateLimiter limiter,
                                int rate)

testRefillOfAverageIntervalRateLimiter

public void testRefillOfAverageIntervalRateLimiter()
                                            throws InterruptedException

Throws:

InterruptedException

testRefillOfFixedIntervalRateLimiter

public void testRefillOfFixedIntervalRateLimiter()
                                          throws InterruptedException

Throws:

InterruptedException