org.apache.hadoop.hbase.monitoring

Interface MonitoredRPCHandler

All Superinterfaces:

Cloneable, MonitoredTask

All Known Implementing Classes:

MonitoredRPCHandlerImpl

@InterfaceAudience.Private
public interface MonitoredRPCHandler
extends MonitoredTask

A MonitoredTask implementation optimized for use with RPC Handlers handling frequent, short duration tasks. String concatenations and object allocations are avoided in methods that will be hit by every RPC call.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.hadoop.hbase.monitoring.MonitoredTask

MonitoredTask.State, MonitoredTask.StatusJournalEntry

Method Summary

Modifier and Type	Method and Description
String	getClient()
String	getRPC()
String	getRPC(boolean withParams)
long	getRPCPacketLength()
long	getRPCQueueTime()
long	getRPCStartTime()
boolean	isOperationRunning()
boolean	isRPCRunning()
void	setConnection(String clientAddress, int remotePort)
void	setRPC(String methodName, Object[] params, long queueTime)
void	setRPCPacket(org.apache.hbase.thirdparty.com.google.protobuf.Message param)

Methods inherited from interface org.apache.hadoop.hbase.monitoring.MonitoredTask

abort, cleanup, clone, expireNow, getCompletionTimestamp, getDescription, getStartTime, getState, getStateTime, getStatus, getStatusJournal, getStatusTime, getWarnTime, markComplete, pause, prettyPrintJournal, resume, setDescription, setStatus, setWarnTime, toJSON, toMap

Method Detail

getRPC

String getRPC()

getRPC

String getRPC(boolean withParams)

getRPCPacketLength

long getRPCPacketLength()

getClient

String getClient()

getRPCStartTime

long getRPCStartTime()

getRPCQueueTime

long getRPCQueueTime()

isRPCRunning

boolean isRPCRunning()

isOperationRunning

boolean isOperationRunning()

setRPC

void setRPC(String methodName,
            Object[] params,
            long queueTime)

setRPCPacket

void setRPCPacket(org.apache.hbase.thirdparty.com.google.protobuf.Message param)

setConnection

void setConnection(String clientAddress,
                   int remotePort)