Package org.apache.hadoop.hbase.replication.regionserver

Class TestReplicationSinkManager

java.lang.Object

org.apache.hadoop.hbase.replication.regionserver.TestReplicationSinkManager

public class TestReplicationSinkManager
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static class	TestReplicationSinkManager.SetServersHBaseReplicationEndpoint	Manage the 'getRegionServers' for the tests below.

Field Summary

Fields

Modifier and Type	Field	Description
static final HBaseClassTestRule	CLASS_RULE
private static final String	PEER_CLUSTER_ID
private org.apache.hadoop.hbase.replication.HBaseReplicationEndpoint	replicationEndpoint
private org.apache.hadoop.hbase.replication.regionserver.ReplicationSinkManager	sinkManager

Constructor Summary

Constructors

Constructor	Description
TestReplicationSinkManager()

Method Summary

Modifier and Type	Method	Description
void	setUp()
void	testChooseSinks()
void	testChooseSinks_LessThanRatioAvailable()
void	testReportBadSink()
void	testReportBadSink_DownToZeroSinks()
void	testReportBadSink_PastThreshold()	Once a SinkPeer has been reported as bad more than BAD_SINK_THRESHOLD times, it should not be replicated to anymore.

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

PEER_CLUSTER_ID

private static final String PEER_CLUSTER_ID

See Also:

• Constant Field Values

sinkManager

private org.apache.hadoop.hbase.replication.regionserver.ReplicationSinkManager sinkManager

replicationEndpoint

private org.apache.hadoop.hbase.replication.HBaseReplicationEndpoint replicationEndpoint

Constructor Details

TestReplicationSinkManager

public TestReplicationSinkManager()

Method Details

setUp

public void setUp()

testChooseSinks

public void testChooseSinks()

testChooseSinks_LessThanRatioAvailable

public void testChooseSinks_LessThanRatioAvailable()

testReportBadSink

public void testReportBadSink()

testReportBadSink_PastThreshold

public void testReportBadSink_PastThreshold()

Once a SinkPeer has been reported as bad more than BAD_SINK_THRESHOLD times, it should not be replicated to anymore.

testReportBadSink_DownToZeroSinks

public void testReportBadSink_DownToZeroSinks()