Sha256: 43adba5f272c0e3061970ab654bb233e53feeb209c189da19372a100803035ad
Contents?: true
Size: 1.59 KB
Versions: 12
Compression:
Stored size: 1.59 KB
Contents
# frozen_string_literal: true
# typed: true
require_relative 'ddtrace'
module Datadog
module Profiling
module TraceIdentifiers
# Helper used to retrieve the trace identifiers (root span id and span id) for a given thread,
# if there is an active trace for that thread for the supported tracing APIs.
#
# This data is used to connect profiles to the traces -- samples in a profile will be tagged with this data and
# the profile can be filtered down to look at only the samples for a given trace.
class Helper
DEFAULT_SUPPORTED_APIS = [
Profiling::TraceIdentifiers::Ddtrace
].freeze
private_constant :DEFAULT_SUPPORTED_APIS
def initialize(
tracer:,
# If this is disabled, the helper will strip the optional trace_resource_container even if provided by the api
endpoint_collection_enabled:,
supported_apis: DEFAULT_SUPPORTED_APIS.map { |api| api.new(tracer: tracer) }
)
@endpoint_collection_enabled = endpoint_collection_enabled
@supported_apis = supported_apis
end
# Expected output of the #trace_identifiers_for
# duck type is [root_span_id, span_id, (optional trace_resource_container)]
def trace_identifiers_for(thread)
@supported_apis.each do |api|
trace_identifiers = api.trace_identifiers_for(thread)
if trace_identifiers
return @endpoint_collection_enabled ? trace_identifiers : trace_identifiers[0..1]
end
end
nil
end
end
end
end
end
Version data entries
12 entries across 12 versions & 1 rubygems