class Protobuf::Rpc::Stat
Constants
- ERROR_TRANSLATIONS
- MODES
Attributes
client[RW]
dispatcher[RW]
end_time[RW]
method_name[RW]
mode[RW]
request_size[RW]
response_size[RW]
server[R]
service[RW]
start_time[RW]
status[RW]
Public Class Methods
new(mode = :SERVER)
click to toggle source
# File lib/protobuf/rpc/stat.rb, line 28 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 91 def client? @mode == :CLIENT end
elapsed_time()
click to toggle source
# File lib/protobuf/rpc/stat.rb, line 41 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 83 def rpc service && method_name ? "#{service}##{method_name}" : nil end
server=(peer)
click to toggle source
# File lib/protobuf/rpc/stat.rb, line 49 def server=(peer) case peer when Array @server = "#{peer[1]}:#{peer[0]}" when String @server = peer end end
server?()
click to toggle source
# File lib/protobuf/rpc/stat.rb, line 87 def server? @mode == :SERVER end
sizes()
click to toggle source
# File lib/protobuf/rpc/stat.rb, line 62 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 70 def start @start_time ||= ::Time.now end
status_string()
click to toggle source
# File lib/protobuf/rpc/stat.rb, line 95 def status_string return "OK" if status.nil? ERROR_TRANSLATIONS.fetch(status, "UNKNOWN_ERROR") end
stop()
click to toggle source
# File lib/protobuf/rpc/stat.rb, line 74 def stop start unless @start_time @end_time ||= ::Time.now end
stopped?()
click to toggle source
# File lib/protobuf/rpc/stat.rb, line 79 def stopped? !end_time.nil? end
to_s()
click to toggle source
# File lib/protobuf/rpc/stat.rb, line 101 def to_s [ server? ? "[SRV]" : "[CLT]", server? ? client : server, trace_id, rpc, sizes, elapsed_time, status_string, @end_time.try(:iso8601), ].compact.join(' - ') end
trace_id()
click to toggle source
# File lib/protobuf/rpc/stat.rb, line 114 def trace_id ::Thread.current.object_id.to_s(16) end