Package org.apache.hadoop.hbase.namequeues

Class TestNamedQueueRecorder

java.lang.Object

org.apache.hadoop.hbase.namequeues.TestNamedQueueRecorder

@Tag("org.apache.hadoop.hbase.testclassification.MediumTests") @Tag("org.apache.hadoop.hbase.testclassification.MasterTests")
public class TestNamedQueueRecorder
extends Object

Tests for Online SlowLog Provider Service

Field Summary

Fields

Modifier and Type	Field	Description
private static final List<org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.NameBytesPair>	CONNECTION_HEADERS
private static final HBaseTestingUtil	HBASE_TESTING_UTILITY
private static int	i
private static final org.slf4j.Logger	LOG
private org.apache.hadoop.hbase.namequeues.NamedQueueRecorder	namedQueueRecorder
private static final List<org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.NameBytesPair>	REQUEST_HEADERS

Constructor Summary

Constructors

Constructor	Description
TestNamedQueueRecorder()

Method Summary

Modifier and Type	Method	Description
private static org.apache.hadoop.conf.Configuration	applySlowLogRecorderConf(int eventSize)
private boolean	confirmPayloadParams(int i, int j, List<org.apache.hadoop.hbase.shaded.protobuf.generated.TooSlowLog.SlowLogPayload> slowLogPayloads)	confirm that for a ringbuffer of slow logs, payload on given index of buffer has expected elements
private static org.apache.hbase.thirdparty.com.google.protobuf.Message	getMessage(Optional<Integer> forcedParamIndex)
private static org.apache.hadoop.hbase.ipc.RpcCall	getRpcCall(String userName)
private static org.apache.hadoop.hbase.ipc.RpcCall	getRpcCall(String userName, int forcedParamIndex)
private static org.apache.hadoop.hbase.ipc.RpcCall	getRpcCall(String userName, Optional<Integer> forcedParamIndex)
(package private) static org.apache.hadoop.hbase.namequeues.RpcLogDetails	getRpcLogDetails(String userName, String clientAddress, String className)
private org.apache.hadoop.hbase.namequeues.RpcLogDetails	getRpcLogDetails(String userName, String clientAddress, String className, boolean isSlowLog, boolean isLargeLog)
(package private) static org.apache.hadoop.hbase.namequeues.RpcLogDetails	getRpcLogDetails(String userName, String clientAddress, String className, int forcedParamIndex)
private static org.apache.hadoop.hbase.namequeues.RpcLogDetails	getRpcLogDetailsOfScan()
private List<org.apache.hadoop.hbase.shaded.protobuf.generated.TooSlowLog.SlowLogPayload>	getSlowLogPayloads(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.SlowLogResponseRequest request)
private static Optional<org.apache.hadoop.hbase.security.User>	getUser(String userName)
void	testConcurrentSlowLogEvents()
void	testOnlieSlowLogConsumption()
void	testOnlineSlowLogConnectionAttributes()
void	testOnlineSlowLogRequestAttributes()
void	testOnlineSlowLogScanPayloadDefaultDisabled()
void	testOnlineSlowLogScanPayloadExplicitlyDisabled()
void	testOnlineSlowLogScanPayloadExplicitlyEnabled()
void	testOnlineSlowLogWithDefaultDisableConfig()
void	testOnlineSlowLogWithDisableConfig()
void	testOnlineSlowLogWithHighRecords()
void	testSlowLargeLogEvents()
void	testSlowLogFilters()
void	testSlowLogFilterWithClientAddress()
void	testSlowLogMixedFilters()

Methods inherited from class java.lang.Object

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

Field Details

LOG

private static final org.slf4j.Logger LOG

HBASE_TESTING_UTILITY

private static final HBaseTestingUtil HBASE_TESTING_UTILITY

REQUEST_HEADERS

private static final List<org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.NameBytesPair> REQUEST_HEADERS

CONNECTION_HEADERS

private static final List<org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.NameBytesPair> CONNECTION_HEADERS

namedQueueRecorder

private org.apache.hadoop.hbase.namequeues.NamedQueueRecorder namedQueueRecorder

i

private static int i

Constructor Details

TestNamedQueueRecorder

public TestNamedQueueRecorder()

Method Details

applySlowLogRecorderConf

private static org.apache.hadoop.conf.Configuration applySlowLogRecorderConf(int eventSize)

confirmPayloadParams

private boolean confirmPayloadParams(int i,
 int j,
 List<org.apache.hadoop.hbase.shaded.protobuf.generated.TooSlowLog.SlowLogPayload> slowLogPayloads)

confirm that for a ringbuffer of slow logs, payload on given index of buffer has expected elements

Parameters:

i - index of ringbuffer logs

j - data value that was put on index i

slowLogPayloads - list of payload retrieved from NamedQueueRecorder

Returns:

if actual values are as per expectations

testOnlieSlowLogConsumption

@Test
public void testOnlieSlowLogConsumption()
                                 throws Exception

Throws:

Exception

getSlowLogPayloads

private List<org.apache.hadoop.hbase.shaded.protobuf.generated.TooSlowLog.SlowLogPayload> getSlowLogPayloads(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.SlowLogResponseRequest request)

testOnlineSlowLogWithHighRecords

@Test
public void testOnlineSlowLogWithHighRecords()
                                      throws Exception

Throws:

Exception

testOnlineSlowLogWithDefaultDisableConfig

@Test
public void testOnlineSlowLogWithDefaultDisableConfig()
                                               throws Exception

Throws:

Exception

testOnlineSlowLogWithDisableConfig

@Test
public void testOnlineSlowLogWithDisableConfig()
                                        throws Exception

Throws:

Exception

testSlowLogFilters

@Test
public void testSlowLogFilters()
                        throws Exception

Throws:

Exception

testSlowLogFilterWithClientAddress

@Test
public void testSlowLogFilterWithClientAddress()
                                        throws Exception

Throws:

Exception

testConcurrentSlowLogEvents

@Test
public void testConcurrentSlowLogEvents()
                                 throws Exception

Throws:

Exception

testSlowLargeLogEvents

@Test
public void testSlowLargeLogEvents()
                            throws Exception

Throws:

Exception

testSlowLogMixedFilters

@Test
public void testSlowLogMixedFilters()
                             throws Exception

Throws:

Exception

testOnlineSlowLogScanPayloadDefaultDisabled

@Test
public void testOnlineSlowLogScanPayloadDefaultDisabled()
                                                 throws Exception

Throws:

Exception

testOnlineSlowLogScanPayloadExplicitlyDisabled

@Test
public void testOnlineSlowLogScanPayloadExplicitlyDisabled()
                                                    throws Exception

Throws:

Exception

testOnlineSlowLogScanPayloadExplicitlyEnabled

@Test
public void testOnlineSlowLogScanPayloadExplicitlyEnabled()
                                                   throws Exception

Throws:

Exception

testOnlineSlowLogRequestAttributes

@Test
public void testOnlineSlowLogRequestAttributes()
                                        throws Exception

Throws:

Exception

testOnlineSlowLogConnectionAttributes

@Test
public void testOnlineSlowLogConnectionAttributes()
                                           throws Exception

Throws:

Exception

getRpcLogDetails

static org.apache.hadoop.hbase.namequeues.RpcLogDetails getRpcLogDetails(String userName,
 String clientAddress,
 String className,
 int forcedParamIndex)

getRpcLogDetails

static org.apache.hadoop.hbase.namequeues.RpcLogDetails getRpcLogDetails(String userName,
 String clientAddress,
 String className)

getRpcLogDetailsOfScan

private static org.apache.hadoop.hbase.namequeues.RpcLogDetails getRpcLogDetailsOfScan()

getRpcLogDetails

private org.apache.hadoop.hbase.namequeues.RpcLogDetails getRpcLogDetails(String userName,
 String clientAddress,
 String className,
 boolean isSlowLog,
 boolean isLargeLog)

getRpcCall

private static org.apache.hadoop.hbase.ipc.RpcCall getRpcCall(String userName)

getRpcCall

private static org.apache.hadoop.hbase.ipc.RpcCall getRpcCall(String userName,
 int forcedParamIndex)

getRpcCall

private static org.apache.hadoop.hbase.ipc.RpcCall getRpcCall(String userName,
 Optional<Integer> forcedParamIndex)

getMessage

private static org.apache.hbase.thirdparty.com.google.protobuf.Message getMessage(Optional<Integer> forcedParamIndex)

getUser

private static Optional<org.apache.hadoop.hbase.security.User> getUser(String userName)