org.apache.hadoop.hbase.replication.regionserver

Class TestReplicationSinkManager

java.lang.Object

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

public class TestReplicationSinkManager
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static HBaseClassTestRule	CLASS_RULE
private static 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 and Description
TestReplicationSinkManager()

Method Summary

Modifier and Type	Method and Description
void	setUp()
void	testChooseSinks_LessThanRatioAvailable()
void	testChooseSinks()
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.
void	testReportBadSink()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

PEER_CLUSTER_ID

private static final String PEER_CLUSTER_ID

See Also:

Constant Field Values

replicationEndpoint

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

sinkManager

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

Constructor Detail

TestReplicationSinkManager

public TestReplicationSinkManager()

Method Detail

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()