Package org.apache.hadoop.hbase.client

Class TestRegistryEndpointsRefresher

java.lang.Object

org.apache.hadoop.hbase.client.TestRegistryEndpointsRefresher

public class TestRegistryEndpointsRefresher
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private CopyOnWriteArrayList<Long>	callTimestamps
static final HBaseClassTestRule	CLASS_RULE
private org.apache.hadoop.conf.Configuration	conf
private static final String	INITIAL_DELAY_SECS_CONFIG_NAME
private static final String	INTERVAL_SECS_CONFIG_NAME
private static final String	MIN_INTERVAL_SECS_CONFIG_NAME
private AtomicInteger	refreshCallCounter
private org.apache.hadoop.hbase.client.RegistryEndpointsRefresher	refresher

Constructor Summary

Constructors

Constructor	Description
TestRegistryEndpointsRefresher()

Method Summary

Modifier and Type	Method	Description
private void	createRefresher(long initialDelaySecs, long intervalSecs, long minIntervalSecs)
private void	refresh()
void	setUp()
void	tearDown()
void	testDisableRefresh()
void	testDurationBetweenRefreshes()
void	testInitialDelay()
void	testPeriodicMasterEndPointRefresh()

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

INITIAL_DELAY_SECS_CONFIG_NAME

private static final String INITIAL_DELAY_SECS_CONFIG_NAME

See Also:

• Constant Field Values

INTERVAL_SECS_CONFIG_NAME

private static final String INTERVAL_SECS_CONFIG_NAME

See Also:

• Constant Field Values

MIN_INTERVAL_SECS_CONFIG_NAME

private static final String MIN_INTERVAL_SECS_CONFIG_NAME

See Also:

• Constant Field Values

conf

private org.apache.hadoop.conf.Configuration conf

refresher

private org.apache.hadoop.hbase.client.RegistryEndpointsRefresher refresher

refreshCallCounter

private AtomicInteger refreshCallCounter

callTimestamps

private CopyOnWriteArrayList<Long> callTimestamps

Constructor Details

TestRegistryEndpointsRefresher

public TestRegistryEndpointsRefresher()

Method Details

setUp

public void setUp()

tearDown

public void tearDown()

refresh

private void refresh()

createRefresher

private void createRefresher(long initialDelaySecs,
 long intervalSecs,
 long minIntervalSecs)

testDisableRefresh

public void testDisableRefresh()

testInitialDelay

public void testInitialDelay()
                      throws InterruptedException

Throws:

InterruptedException

testPeriodicMasterEndPointRefresh

public void testPeriodicMasterEndPointRefresh()

testDurationBetweenRefreshes

public void testDurationBetweenRefreshes()