Package org.apache.hadoop.hbase.client

Class TestRegistryEndpointsRefresher

java.lang.Object

org.apache.hadoop.hbase.client.TestRegistryEndpointsRefresher

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

Field Summary

Fields

Modifier and Type	Field	Description
private CopyOnWriteArrayList<Long>	callTimestamps
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

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

@BeforeEach
public void setUp()

tearDown

@AfterEach
public void tearDown()

refresh

private void refresh()

createRefresher

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

testDisableRefresh

@Test
public void testDisableRefresh()

testInitialDelay

@Test
public void testInitialDelay()
                      throws InterruptedException

Throws:

InterruptedException

testPeriodicMasterEndPointRefresh

@Test
public void testPeriodicMasterEndPointRefresh()

testDurationBetweenRefreshes

@Test
public void testDurationBetweenRefreshes()