Sha256: 0d15c7efc8be8d881707ae42f150d551677f81312b6a768cf1bc919553c0c2cf
Contents?: true
Size: 1.26 KB
Versions: 1
Compression:
Stored size: 1.26 KB
Contents
module Imprint class Tracer TRACER_HEADER = 'HTTP_IMPRINTID' TRACER_KEY = 'IMPRINTID' RAILS_REQUEST_ID = "action_dispatch.request_id" TRACE_ID_DEFAULT = "-1" TRACER_TIMESTAMP = "TIMESTAMP" TRACE_CHARS = [('a'..'z'), ('A'..'Z')].map { |i| i.to_a }.flatten def self.set_trace_id(id, rack_env = {}) Thread.current[TRACER_TIMESTAMP] ||= Time.now.to_f Thread.current[TRACER_KEY] = id # setting to the rack_env, gives error tracking support in some systems rack_env[TRACER_KEY] = id end def self.get_trace_id if Thread.current.key?(TRACER_KEY) Thread.current[TRACER_KEY] else TRACE_ID_DEFAULT end end def self.get_trace_timestamp Thread.current[TRACER_TIMESTAMP] ||= Time.now.to_f end def self.insert_trace_id_in_message(message) if message && message.is_a?(String) && message.length > 1 && !message.include?('trace_id=') trace_id = get_trace_id if trace_id && trace_id != TRACE_ID_DEFAULT message.insert 0, "[#{get_trace_timestamp}] " message.gsub!("\n"," trace_id=#{trace_id}\n") end end end def self.rand_trace_id (0...6).map { TRACE_CHARS[rand(TRACE_CHARS.length)] }.join end end end
Version data entries
1 entries across 1 versions & 1 rubygems
Version | Path |
---|---|
imprint-1.4.3.pre | lib/imprint/tracer.rb |