Sha256: 5c7d743211a76617dc00a57976857cb0b988ed0ea75250e1810ed3d46b95e72d
Contents?: true
Size: 1.87 KB
Versions: 1
Compression:
Stored size: 1.87 KB
Contents
# frozen_string_literal: true # typed: true require_relative 'helpers' require_relative '../trace_digest' module Datadog module Tracing module Distributed # B3-style trace propagation. # @see https://github.com/openzipkin/b3-propagation#multiple-headers class B3 B3_TRACE_ID_KEY = 'x-b3-traceid' B3_SPAN_ID_KEY = 'x-b3-spanid' B3_SAMPLED_KEY = 'x-b3-sampled' def initialize( fetcher:, trace_id_key: B3_TRACE_ID_KEY, span_id_key: B3_SPAN_ID_KEY, sampled_key: B3_SAMPLED_KEY ) @trace_id_key = trace_id_key @span_id_key = span_id_key @sampled_key = sampled_key @fetcher = fetcher end def inject!(digest, data = {}) return if digest.nil? # DEV: We need these to be hex encoded data[@trace_id_key] = digest.trace_id.to_s(16) data[@span_id_key] = digest.span_id.to_s(16) if digest.trace_sampling_priority sampling_priority = Helpers.clamp_sampling_priority( digest.trace_sampling_priority ) data[@sampled_key] = sampling_priority.to_s end data end def extract(data) # DEV: B3 doesn't have "origin" fetcher = @fetcher.new(data) trace_id = fetcher.id(@trace_id_key, base: 16) span_id = fetcher.id(@span_id_key, base: 16) # We don't need to try and convert sampled since B3 supports 0/1 (AUTO_REJECT/AUTO_KEEP) sampling_priority = fetcher.number(@sampled_key) # Return early if this propagation is not valid return unless trace_id && span_id TraceDigest.new( trace_id: trace_id, span_id: span_id, trace_sampling_priority: sampling_priority ) end end end end end
Version data entries
1 entries across 1 versions & 1 rubygems
Version | Path |
---|---|
ddtrace-1.7.0 | lib/datadog/tracing/distributed/b3.rb |