public abstract class TestReplicationStateBasic
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
protected static java.lang.String |
ID_ONE |
protected static java.lang.String |
ID_TWO |
protected static java.lang.String |
KEY_ONE |
protected static java.lang.String |
KEY_TWO |
protected java.lang.String |
OUR_ID |
protected java.lang.String |
OUR_KEY |
protected ReplicationPeers |
rp |
protected ReplicationQueues |
rq1 |
protected ReplicationQueues |
rq2 |
protected ReplicationQueues |
rq3 |
protected ReplicationQueuesClient |
rqc |
protected java.lang.String |
server1 |
protected java.lang.String |
server2 |
protected java.lang.String |
server3 |
protected static int |
ZK_MAX_COUNT |
protected static int |
ZK_SLEEP_INTERVAL |
protected static int |
zkTimeoutCount |
Constructor and Description |
---|
TestReplicationStateBasic() |
Modifier and Type | Method and Description |
---|---|
protected void |
assertConnectedPeerStatus(boolean status,
java.lang.String peerId) |
protected void |
assertNumberOfPeers(int total) |
protected void |
populateQueues() |
void |
setUp() |
void |
testHfileRefsReplicationQueues() |
void |
testRemovePeerForHFileRefs() |
void |
testReplicationPeers() |
void |
testReplicationQueues() |
void |
testReplicationQueuesClient() |
protected ReplicationQueues rq1
protected ReplicationQueues rq2
protected ReplicationQueues rq3
protected ReplicationQueuesClient rqc
protected java.lang.String server1
protected java.lang.String server2
protected java.lang.String server3
protected ReplicationPeers rp
protected static final java.lang.String ID_ONE
protected static final java.lang.String ID_TWO
protected static java.lang.String KEY_ONE
protected static java.lang.String KEY_TWO
protected java.lang.String OUR_ID
protected java.lang.String OUR_KEY
protected static int zkTimeoutCount
protected static final int ZK_MAX_COUNT
protected static final int ZK_SLEEP_INTERVAL
public void setUp()
public void testReplicationQueuesClient() throws ReplicationException, KeeperException
ReplicationException
KeeperException
public void testReplicationQueues() throws ReplicationException
ReplicationException
public void testHfileRefsReplicationQueues() throws ReplicationException, KeeperException
ReplicationException
KeeperException
public void testRemovePeerForHFileRefs() throws ReplicationException, KeeperException
ReplicationException
KeeperException
public void testReplicationPeers() throws java.lang.Exception
java.lang.Exception
protected void assertConnectedPeerStatus(boolean status, java.lang.String peerId) throws java.lang.Exception
java.lang.Exception
protected void assertNumberOfPeers(int total)
protected void populateQueues() throws ReplicationException
ReplicationException