class ThriftServer::LogSubscriber
Public Instance Methods
rpc_error(rpc, ex, meta)
click to toggle source
# File lib/thrift_server/log_subscriber.rb, line 38 def rpc_error(rpc, ex, meta) logger.info :processor do "%s => Error! %s (%.2fms)" % [ rpc.name, ex.class.name, meta.fetch(:latency) ] end logger.error ex end
rpc_exception(rpc, ex, meta)
click to toggle source
# File lib/thrift_server/log_subscriber.rb, line 50 def rpc_exception(rpc, ex, meta) logger.info :processor do "%s => %s (%.2fms)" % [ rpc.name, rpc.exception_name(ex), meta.fetch(:latency) ] end end
rpc_ok(rpc, response, meta)
click to toggle source
# File lib/thrift_server/log_subscriber.rb, line 29 def rpc_ok(rpc, response, meta) logger.info :processor do "%s => OK (%.2fms)" % [ rpc.name, meta.fetch(:latency) ] end end
server_connection_closed(addr)
click to toggle source
# File lib/thrift_server/log_subscriber.rb, line 20 def server_connection_closed(addr) logger.debug :server do "%s:%d disconnected" % [ addr.ip_address, addr.ip_port ] end end
server_connection_opened(addr)
click to toggle source
# File lib/thrift_server/log_subscriber.rb, line 11 def server_connection_opened(addr) logger.debug :server do "%s:%d connected" % [ addr.ip_address, addr.ip_port ] end end
thread_pool_server_pool_change(meta)
click to toggle source
# File lib/thrift_server/log_subscriber.rb, line 5 def thread_pool_server_pool_change(meta) logger.debug :server do "Thread pool change: %+d" % [ meta.fetch(:delta) ] end end