org.apache.avro.ipc.stats

Class StatsPlugin

java.lang.Object

org.apache.avro.ipc.RPCPlugin

org.apache.avro.ipc.stats.StatsPlugin

public class StatsPlugin
extends RPCPlugin

Collects count and latency statistics about RPC calls. Keeps data for every method. Can be added to a Requestor (client) or Responder (server). This uses milliseconds as the standard unit of measure throughout the class, stored in floats.

Field Summary

Fields

Modifier and Type	Field and Description
Date	startupTime How long I've been alive

Constructor Summary

Constructors

Constructor and Description
StatsPlugin() Construct a plugin with default (system) ticks, and default histogram segmentation.

Method Summary

Methods

Modifier and Type	Method and Description
void	clientReceiveResponse(RPCContext context) This method is invoked at the client after the call is executed, and after the client receives the response
void	clientSendRequest(RPCContext context) This method is invoked at the client before it issues the RPC call.
void	serverReceiveRequest(RPCContext context) This method is invoked at the RPC server when the request is received, but before the call itself is executed
void	serverSendResponse(RPCContext context) This method is invoked at the server before the response is executed, but before the response has been formulated

Methods inherited from class org.apache.avro.ipc.RPCPlugin

clientFinishConnect, clientStartConnect, serverConnecting

Methods inherited from class java.lang.Object

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

Field Detail

startupTime

public Date startupTime

How long I've been alive

Constructor Detail

StatsPlugin

public StatsPlugin()

Construct a plugin with default (system) ticks, and default histogram segmentation.

Method Detail

serverReceiveRequest

public void serverReceiveRequest(RPCContext context)

Description copied from class: RPCPlugin

This method is invoked at the RPC server when the request is received, but before the call itself is executed

Overrides:

serverReceiveRequest in class RPCPlugin

Parameters:

context - the per-call rpc context (in/out parameter)

serverSendResponse

public void serverSendResponse(RPCContext context)

Description copied from class: RPCPlugin

This method is invoked at the server before the response is executed, but before the response has been formulated

Overrides:

serverSendResponse in class RPCPlugin

Parameters:

context - the per-call rpc context (in/out parameter)

clientSendRequest

public void clientSendRequest(RPCContext context)

Description copied from class: RPCPlugin

This method is invoked at the client before it issues the RPC call.

Overrides:

clientSendRequest in class RPCPlugin

Parameters:

context - the per-call rpc context (in/out parameter)

clientReceiveResponse

public void clientReceiveResponse(RPCContext context)

Description copied from class: RPCPlugin

This method is invoked at the client after the call is executed, and after the client receives the response

Overrides:

clientReceiveResponse in class RPCPlugin

Parameters:

context - the per-call rpc context