Class: ThriftServer::LogSubscriber

Inherits:
Object
  • Object
show all
Defined in:
lib/thrift_server/log_subscriber.rb

Instance Method Summary collapse

Instance Method Details

#rpc_error(rpc, ex, meta) ⇒ Object 



38
39
40
41
42
43
44
45
46
47
48
 
# 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) ⇒ Object 



50
51
52
53
54
55
56
57
58
 
# 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) ⇒ Object 



29
30
31
32
33
34
35
36
 
# 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) ⇒ Object 



20
21
22
23
24
25
26
27
 
# 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) ⇒ Object 



11
12
13
14
15
16
17
18
 
# 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) ⇒ Object 



5
6
7
8
9
 
# 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