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