Sha256: 9a8810c76759c470bb4a2e833365406722621b46afb1ce28155128565c5083b5
Contents?: true
Size: 1.01 KB
Versions: 14
Compression:
Stored size: 1.01 KB
Contents
require 'ddtrace/span'
require 'ddtrace/ext/distributed'
module Datadog
# DistributedHeaders provides easy access and validation to headers
class DistributedHeaders
include Ext::DistributedTracing
def initialize(env)
@env = env
end
def valid?
# Sampling priority is optional.
trace_id && parent_id
end
def trace_id
id HTTP_HEADER_TRACE_ID
end
def parent_id
id HTTP_HEADER_PARENT_ID
end
def sampling_priority
hdr = header(HTTP_HEADER_SAMPLING_PRIORITY)
# It's important to make a difference between no header,
# and a header defined to zero.
return unless hdr
value = hdr.to_i
return if value < 0
value
end
private
def header(name)
rack_header = "http-#{name}".upcase!.tr('-', '_')
@env[rack_header]
end
def id(header)
value = header(header).to_i
return if value.zero? || value >= Span::MAX_ID
value < 0 ? value + 0x1_0000_0000_0000_0000 : value
end
end
end
Version data entries
14 entries across 14 versions & 1 rubygems