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