Package org.apache.hadoop.hbase.tool

Class TestCanaryTool

java.lang.Object

org.apache.hadoop.hbase.tool.TestCanaryTool

public class TestCanaryTool
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final HBaseClassTestRule	CLASS_RULE
private static final byte[]	COLUMN
private static final byte[]	FAMILY
private org.apache.logging.log4j.core.Appender	mockAppender
org.junit.rules.TestName	name
private HBaseTestingUtil	testingUtility

Constructor Summary

Constructors

Constructor	Description
TestCanaryTool()

Method Summary

Modifier and Type	Method	Description
private String	getPageContent(URL url)
private void	runRegionserverCanary()
void	setUp()
private static ExecutorService	startCanaryToolInBackground(org.apache.hadoop.hbase.tool.CanaryTool.RegionStdOutSink sink, org.apache.hadoop.conf.Configuration configuration)
void	tearDown()
void	testBasicCanaryWorks()
void	testBasicZookeeperCanaryWorks()
void	testCanaryRegionTaskReadAllCF()
void	testCanaryRegionTaskResult()
void	testCanaryStopsScanningAfterTimeout()	When CanaryTool times out, it should stop scanning and shutdown quickly and gracefully.
void	testRawScanConfig()
void	testReadTableTimeouts()
void	testRegionserverNoRegions()
void	testRegionserverWithRegions()
void	testWebUI()
void	testWebUIWithFailures()
void	testWriteTableTimeout()
void	testZookeeperCanaryPermittedFailuresArgumentWorks()
private void	testZookeeperCanaryWithArgs(String[] args)

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

testingUtility

private HBaseTestingUtil testingUtility

FAMILY

private static final byte[] FAMILY

COLUMN

private static final byte[] COLUMN

name

public org.junit.rules.TestName name

mockAppender

private org.apache.logging.log4j.core.Appender mockAppender

Constructor Details

TestCanaryTool

public TestCanaryTool()

Method Details

setUp

public void setUp()
           throws Exception

Throws:

Exception

tearDown

public void tearDown()
              throws Exception

Throws:

Exception

testBasicZookeeperCanaryWorks

public void testBasicZookeeperCanaryWorks()
                                   throws Exception

Throws:

Exception

testZookeeperCanaryPermittedFailuresArgumentWorks

public void testZookeeperCanaryPermittedFailuresArgumentWorks()
                                                       throws Exception

Throws:

Exception

testBasicCanaryWorks

public void testBasicCanaryWorks()
                          throws Exception

Throws:

Exception

testCanaryStopsScanningAfterTimeout

public void testCanaryStopsScanningAfterTimeout()
                                         throws Exception

When CanaryTool times out, it should stop scanning and shutdown quickly and gracefully. This test helps to confirm that threadpools do not continue executing work after the canary finishes. It also verifies sink behavior and measures correct failure counts in the sink.

Throws:

Exception - if it can't create a table, communicate with minicluster, or run the canary.

testCanaryRegionTaskReadAllCF

public void testCanaryRegionTaskReadAllCF()
                                   throws Exception

Throws:

Exception

testCanaryRegionTaskResult

public void testCanaryRegionTaskResult()
                                throws Exception

Throws:

Exception

testReadTableTimeouts

public void testReadTableTimeouts()
                           throws Exception

Throws:

Exception

testWriteTableTimeout

public void testWriteTableTimeout()
                           throws Exception

Throws:

Exception

testRegionserverNoRegions

public void testRegionserverNoRegions()
                               throws Exception

Throws:

Exception

testRegionserverWithRegions

public void testRegionserverWithRegions()
                                 throws Exception

Throws:

Exception

testRawScanConfig

public void testRawScanConfig()
                       throws Exception

Throws:

Exception

runRegionserverCanary

private void runRegionserverCanary()
                            throws Exception

Throws:

Exception

testZookeeperCanaryWithArgs

private void testZookeeperCanaryWithArgs(String[] args)
                                  throws Exception

Throws:

Exception

testWebUI

public void testWebUI()
               throws Exception

Throws:

Exception

testWebUIWithFailures

public void testWebUIWithFailures()
                           throws Exception

Throws:

Exception

startCanaryToolInBackground

private static ExecutorService startCanaryToolInBackground(org.apache.hadoop.hbase.tool.CanaryTool.RegionStdOutSink sink,
 org.apache.hadoop.conf.Configuration configuration)

getPageContent

private String getPageContent(URL url)
                       throws IOException,
InterruptedException

Throws:

IOException

InterruptedException