class ThriftServer::RpcMetricsSubscriber
Public Instance Methods
rpc_error(rpc, ex, meta)
click to toggle source
# File lib/thrift_server/rpc_metrics_subscriber.rb, line 20 def rpc_error(rpc, ex, meta) statsd.increment "rpc.#{rpc}.error" statsd.timing "rpc.#{rpc}.latency", meta.fetch(:latency) end
rpc_exception(rpc, ex, meta)
click to toggle source
# File lib/thrift_server/rpc_metrics_subscriber.rb, line 14 def rpc_exception(rpc, ex, meta) statsd.increment "rpc.#{rpc}.exception" statsd.increment "rpc.#{rpc}.exception.#{rpc.exception_name(ex)}" statsd.timing "rpc.#{rpc}.latency", meta.fetch(:latency) end
rpc_incoming(rpc)
click to toggle source
# File lib/thrift_server/rpc_metrics_subscriber.rb, line 5 def rpc_incoming(rpc) statsd.increment "rpc.#{rpc}.incoming" end
rpc_ok(rpc, response, meta)
click to toggle source
# File lib/thrift_server/rpc_metrics_subscriber.rb, line 9 def rpc_ok(rpc, response, meta) statsd.increment "rpc.#{rpc}.success" statsd.timing "rpc.#{rpc}.latency", meta.fetch(:latency) end