Sha256: 25c4baf7dc0ae728bbb7d3a20d8b13bb7954f3eed4368a2b3eacd819f787415f
Contents?: true
Size: 1.57 KB
Versions: 10
Compression:
Stored size: 1.57 KB
Contents
require 'date'
require 'protobuf/logger'
module Protobuf
module Rpc
class Stat
attr_accessor :mode, :start_time, :end_time, :request_size, :dispatcher
attr_accessor :response_size, :client, :server, :service, :method_name
MODES = [:SERVER, :CLIENT].freeze
def initialize(mode = :SERVER)
@mode = mode
start
end
def client=(client_host)
@client = client_host
end
def client
@client || nil
end
def method_name
@method_name ||= @dispatcher.try(:service).try(:rpc)
end
def server=(peer)
@server = {:port => peer[0], :ip => peer[1]}
end
def server
@server ? "#{@server[:ip]}:#{@server[:port]}" : nil
end
def service
@service ||= @dispatcher.try(:service).class.name
end
def sizes
"#{@request_size || 0}B/#{@response_size || 0}B"
end
def start
@start_time ||= Time.now
end
def stop
start unless @start_time
@end_time ||= Time.now
end
def rpc
service && method_name ? "#{service}##{method_name}" : nil
end
def elapsed_time
(start_time && end_time ? "#{(end_time - start_time).round(4)}s" : nil)
end
def server?
@mode == :SERVER
end
def client?
@mode == :CLIENT
end
def to_s
[
server? ? "[SRV]" : "[CLT]",
rpc,
elapsed_time,
sizes,
server? ? server : client
].compact.join(' - ')
end
end
end
end
Version data entries
10 entries across 10 versions & 1 rubygems