Package org.apache.hadoop.hbase.namequeues

Class TestNamedQueueRecorder

java.lang.Object

org.apache.hadoop.hbase.namequeues.TestNamedQueueRecorder

public class TestNamedQueueRecorder
extends Object

Tests for Online SlowLog Provider Service

Field Summary

Fields

Modifier and Type	Field	Description
static final HBaseClassTestRule	CLASS_RULE
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

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

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

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

public void testOnlineSlowLogWithHighRecords()
                                      throws Exception

Throws:

Exception

testOnlineSlowLogWithDefaultDisableConfig

public void testOnlineSlowLogWithDefaultDisableConfig()
                                               throws Exception

Throws:

Exception

testOnlineSlowLogWithDisableConfig

public void testOnlineSlowLogWithDisableConfig()
                                        throws Exception

Throws:

Exception

testSlowLogFilters

public void testSlowLogFilters()
                        throws Exception

Throws:

Exception

testSlowLogFilterWithClientAddress

public void testSlowLogFilterWithClientAddress()
                                        throws Exception

Throws:

Exception

testConcurrentSlowLogEvents

public void testConcurrentSlowLogEvents()
                                 throws Exception

Throws:

Exception

testSlowLargeLogEvents

public void testSlowLargeLogEvents()
                            throws Exception

Throws:

Exception

testSlowLogMixedFilters

public void testSlowLogMixedFilters()
                             throws Exception

Throws:

Exception

testOnlineSlowLogScanPayloadDefaultDisabled

public void testOnlineSlowLogScanPayloadDefaultDisabled()
                                                 throws Exception

Throws:

Exception

testOnlineSlowLogScanPayloadExplicitlyDisabled

public void testOnlineSlowLogScanPayloadExplicitlyDisabled()
                                                    throws Exception

Throws:

Exception

testOnlineSlowLogScanPayloadExplicitlyEnabled

public void testOnlineSlowLogScanPayloadExplicitlyEnabled()
                                                   throws Exception

Throws:

Exception

testOnlineSlowLogRequestAttributes

public void testOnlineSlowLogRequestAttributes()
                                        throws Exception

Throws:

Exception

testOnlineSlowLogConnectionAttributes

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)