public class TestReplicationStateZKImpl extends TestReplicationStateBasic
| Modifier and Type | Class and Description |
|---|---|
(package private) static class |
TestReplicationStateZKImpl.DummyServer |
| Modifier and Type | Field and Description |
|---|---|
static HBaseClassTestRule |
CLASS_RULE |
private static org.apache.hadoop.conf.Configuration |
conf |
private static org.slf4j.Logger |
LOG |
private static String |
replicationZNode |
private org.apache.hadoop.hbase.replication.ReplicationQueuesZKImpl |
rqZK |
private static HBaseTestingUtility |
utility |
private static org.apache.hadoop.hbase.zookeeper.ZKWatcher |
zkw |
ID_ONE, ID_TWO, KEY_ONE, KEY_TWO, OUR_ID, OUR_KEY, rp, rq1, rq2, rq3, rqc, server1, server2, server3, ZK_MAX_COUNT, ZK_SLEEP_INTERVAL, zkTimeoutCount| Constructor and Description |
|---|
TestReplicationStateZKImpl() |
| Modifier and Type | Method and Description |
|---|---|
private static String |
initPeerClusterState(String baseZKNode) |
void |
setUp() |
static void |
setUpBeforeClass() |
void |
tearDown() |
static void |
tearDownAfterClass() |
void |
testIsPeerPath_ActualPeerPath() |
void |
testIsPeerPath_PathToChildOfPeerNode() |
void |
testIsPeerPath_PathToParentOfPeerNode() |
assertConnectedPeerStatus, assertNumberOfPeers, populateQueues, testHfileRefsReplicationQueues, testInvalidClusterKeys, testRemovePeerForHFileRefs, testReplicationPeers, testReplicationQueues, testReplicationQueuesClientpublic static final HBaseClassTestRule CLASS_RULE
private static final org.slf4j.Logger LOG
private static org.apache.hadoop.conf.Configuration conf
private static HBaseTestingUtility utility
private static org.apache.hadoop.hbase.zookeeper.ZKWatcher zkw
private static String replicationZNode
private org.apache.hadoop.hbase.replication.ReplicationQueuesZKImpl rqZK
public TestReplicationStateZKImpl()
public static void setUpBeforeClass() throws Exception
Exceptionprivate static String initPeerClusterState(String baseZKNode) throws IOException, org.apache.zookeeper.KeeperException
IOExceptionorg.apache.zookeeper.KeeperExceptionpublic void setUp()
setUp in class TestReplicationStateBasicpublic void tearDown() throws org.apache.zookeeper.KeeperException, IOException
org.apache.zookeeper.KeeperExceptionIOExceptionpublic static void tearDownAfterClass() throws Exception
Exceptionpublic void testIsPeerPath_PathToParentOfPeerNode()
public void testIsPeerPath_PathToChildOfPeerNode()
public void testIsPeerPath_ActualPeerPath()
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.