Package org.apache.hadoop.hbase.quotas

Class TestRateLimiter

java.lang.Object

org.apache.hadoop.hbase.quotas.TestRateLimiter

@Tag("org.apache.hadoop.hbase.testclassification.RegionServerTests") @Tag("org.apache.hadoop.hbase.testclassification.SmallTests")
public class TestRateLimiter
extends Object

Verify the behaviour of the Rate Limiter.

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

Constructor Details

TestRateLimiter

public TestRateLimiter()

Method Details

testWaitIntervalTimeUnitSeconds

@Test
public void testWaitIntervalTimeUnitSeconds()

testWaitIntervalTimeUnitMinutes

@Test
public void testWaitIntervalTimeUnitMinutes()

testWaitIntervalTimeUnitHours

@Test
public void testWaitIntervalTimeUnitHours()

testWaitIntervalTimeUnitDays

@Test
public void testWaitIntervalTimeUnitDays()

testWaitInterval

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

testOverconsumptionAverageIntervalRefillStrategy

@Test
public void testOverconsumptionAverageIntervalRefillStrategy()

testOverconsumptionFixedIntervalRefillStrategy

@Test
public void testOverconsumptionFixedIntervalRefillStrategy()
                                                    throws InterruptedException

Throws:

InterruptedException

testFixedIntervalResourceAvailability

@Test
public void testFixedIntervalResourceAvailability()
                                           throws Exception

Throws:

Exception

testLimiterBySmallerRate

@Test
public void testLimiterBySmallerRate()
                              throws InterruptedException

Throws:

InterruptedException

testCanExecuteOfAverageIntervalRateLimiter

@Test
public void testCanExecuteOfAverageIntervalRateLimiter()
                                                throws InterruptedException

Throws:

InterruptedException

testCanExecuteOfFixedIntervalRateLimiter

@Test
public void testCanExecuteOfFixedIntervalRateLimiter()
                                              throws InterruptedException

Throws:

InterruptedException

testCanExecuteByRate

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

testRefillOfAverageIntervalRateLimiter

@Test
public void testRefillOfAverageIntervalRateLimiter()
                                            throws InterruptedException

Throws:

InterruptedException

testRefillOfFixedIntervalRateLimiter

@Test
public void testRefillOfFixedIntervalRateLimiter()
                                          throws InterruptedException

Throws:

InterruptedException

testUnconfiguredLimiters

@Test
public void testUnconfiguredLimiters()
                              throws InterruptedException

Throws:

InterruptedException

testExtremeLimiters

@Test
public void testExtremeLimiters()
                         throws InterruptedException

Throws:

InterruptedException

testLimiterCompensationOverflow

@Test
public void testLimiterCompensationOverflow()
                                     throws InterruptedException

Throws:

InterruptedException

itRunsFullWithPartialRefillInterval

@Test
public void itRunsFullWithPartialRefillInterval()

itRunsPartialRefillIntervals

@Test
public void itRunsPartialRefillIntervals()

itRunsRepeatedPartialRefillIntervals

@Test
public void itRunsRepeatedPartialRefillIntervals()