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