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 and Description
static HBaseClassTestRule	CLASS_RULE
private static HBaseTestingUtility	HBASE_TESTING_UTILITY
private static int	i
private static org.slf4j.Logger	LOG
private org.apache.hadoop.hbase.namequeues.NamedQueueRecorder	namedQueueRecorder

Constructor Summary

Constructors

Constructor and Description
TestNamedQueueRecorder()

Method Summary

Modifier and Type	Method and 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()
private static org.apache.hadoop.hbase.ipc.RpcCall	getRpcCall(String userName)
(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)
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	testOnlineSlowLogWithDefaultDisableConfig()
void	testOnlineSlowLogWithDisableConfig()
void	testOnlineSlowLogWithHighRecords()
void	testSlowLargeLogEvents()
void	testSlowLogFilters()
void	testSlowLogMixedFilters()

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

LOG

private static final org.slf4j.Logger LOG

HBASE_TESTING_UTILITY

private static final HBaseTestingUtility HBASE_TESTING_UTILITY

namedQueueRecorder

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

i

private static int i

Constructor Detail

TestNamedQueueRecorder

public TestNamedQueueRecorder()

Method Detail

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

testConcurrentSlowLogEvents

public void testConcurrentSlowLogEvents()
                                 throws Exception

Throws:

Exception

testSlowLargeLogEvents

public void testSlowLargeLogEvents()
                            throws Exception

Throws:

Exception

testSlowLogMixedFilters

public void testSlowLogMixedFilters()
                             throws Exception

Throws:

Exception

getRpcLogDetails

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

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)

getMessage

private static org.apache.hbase.thirdparty.com.google.protobuf.Message getMessage()

getUser

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