class Protobuf::Rpc::Stat
Constants
- MODES
Attributes
client[RW]
dispatcher[RW]
end_time[RW]
method_name[RW]
mode[RW]
request_size[RW]
response_size[RW]
server[RW]
service[RW]
start_time[RW]
Public Class Methods
new(mode = :SERVER)
click to toggle source
# File lib/protobuf/rpc/stat.rb, line 13 def initialize(mode = :SERVER) @mode = mode @request_size = 0 @response_size = 0 start end
Public Instance Methods
client?()
click to toggle source
# File lib/protobuf/rpc/stat.rb, line 75 def client? @mode == :CLIENT end
elapsed_time()
click to toggle source
# File lib/protobuf/rpc/stat.rb, line 26 def elapsed_time (start_time && end_time ? "#{(end_time - start_time).round(4)}s" : nil) end
rpc()
click to toggle source
# File lib/protobuf/rpc/stat.rb, line 67 def rpc service && method_name ? "#{service}##{method_name}" : nil end
server=(peer)
click to toggle source
# File lib/protobuf/rpc/stat.rb, line 34 def server=(peer) @server = { :port => peer[0], :ip => peer[1] } end
server?()
click to toggle source
# File lib/protobuf/rpc/stat.rb, line 71 def server? @mode == :SERVER end
sizes()
click to toggle source
# File lib/protobuf/rpc/stat.rb, line 46 def sizes if stopped? "#{@request_size}B/#{@response_size}B" else "#{@request_size}B/-" end end
start()
click to toggle source
# File lib/protobuf/rpc/stat.rb, line 54 def start @start_time ||= ::Time.now end
stop()
click to toggle source
# File lib/protobuf/rpc/stat.rb, line 58 def stop start unless @start_time @end_time ||= ::Time.now end
stopped?()
click to toggle source
# File lib/protobuf/rpc/stat.rb, line 63 def stopped? !end_time.nil? end
to_s()
click to toggle source
# File lib/protobuf/rpc/stat.rb, line 79 def to_s [ server? ? "[SRV]" : "[CLT]", server? ? client : server, trace_id, rpc, sizes, elapsed_time, @end_time.try(:iso8601), ].compact.join(' - ') end
trace_id()
click to toggle source
# File lib/protobuf/rpc/stat.rb, line 91 def trace_id ::Thread.current.object_id.to_s(16) end