Sha256: b6710a2448fdd946faf2418321b9e58addaaafb0707b0a86bd8b8f732acab640
Contents?: true
Size: 1.63 KB
Versions: 10
Compression:
Stored size: 1.63 KB
Contents
# frozen_string_literal: true
require_relative 'component'
require_relative 'http/integration'
require_relative 'http/distributed/propagation'
module Datadog
module Tracing
module Contrib
# `Net/HTTP` integration public API
# @public_api
module HTTP
# Inject distributed headers into the given request
# @param digest [Datadog::Tracing::TraceDigest] the trace to inject
# @param data [Hash] the request to inject
def self.inject(digest, data)
raise 'Please invoke Datadog.configure at least once before calling this method' unless @propagation
@propagation.inject!(digest, data)
end
# Extract distributed headers from the given request
# @param data [Hash] the request to extract from
# @return [Datadog::Tracing::TraceDigest,nil] the extracted trace digest or nil if none was found
def self.extract(data)
raise 'Please invoke Datadog.configure at least once before calling this method' unless @propagation
@propagation.extract(data)
end
Contrib::Component.register('http') do |config|
tracing = config.tracing
# DEV: evaluate propagation_style in case it overrides propagation_style_extract & propagation_extract_first
tracing.propagation_style
@propagation = HTTP::Distributed::Propagation.new(
propagation_style_inject: tracing.propagation_style_inject,
propagation_style_extract: tracing.propagation_style_extract,
propagation_extract_first: tracing.propagation_extract_first
)
end
end
end
end
end
Version data entries
10 entries across 10 versions & 1 rubygems