class ThriftServer::ServerMetricsSubscriber
Public Instance Methods
rpc_error(rpc, ex, meta)
click to toggle source
# File lib/thrift_server/server_metrics_subscriber.rb, line 27 def rpc_error(rpc, ex, meta) statsd.increment 'rpc.error' statsd.timing 'rpc.latency', meta.fetch(:latency) end
rpc_exception(rpc, ex, meta)
click to toggle source
# File lib/thrift_server/server_metrics_subscriber.rb, line 22 def rpc_exception(rpc, ex, meta) statsd.increment 'rpc.exception' statsd.timing 'rpc.latency', meta.fetch(:latency) end
rpc_incoming(rpc)
click to toggle source
# File lib/thrift_server/server_metrics_subscriber.rb, line 13 def rpc_incoming(rpc) statsd.increment 'rpc.incoming' end
rpc_ok(rpc, response, meta)
click to toggle source
# File lib/thrift_server/server_metrics_subscriber.rb, line 17 def rpc_ok(rpc, response, meta) statsd.increment 'rpc.success' statsd.timing 'rpc.latency', meta.fetch(:latency) end
server_connection_closed(*)
click to toggle source
# File lib/thrift_server/server_metrics_subscriber.rb, line 9 def server_connection_closed(*) statsd.gauge 'server.connection.active', '-1' end
server_connection_opened(*)
click to toggle source
# File lib/thrift_server/server_metrics_subscriber.rb, line 5 def server_connection_opened(*) statsd.gauge 'server.connection.active', '+1' end