Skip to content

fix: instrument datadog APM trace propaagation from parent thread to child thread #4

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Draft
saada wants to merge 1 commit into
base: main
Choose a base branch
from
Draft

fix: instrument datadog APM trace propaagation from parent thread to child thread #4

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
18 changes: 18 additions & 0 deletions lib/ld-eventsource/client.rb
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -156,7 +156,9 @@ def initialize(uri,

yield self if block_given?

trace_digest = capture_trace_digest
Thread.new do
continue_trace_context(trace_digest)
run_stream
end
end
Expand Down Expand Up @@ -379,5 +381,21 @@ def build_headers
h['Last-Event-Id'] = @last_id if !@last_id.nil? && @last_id != ""
h.merge(@headers)
end

def capture_trace_digest
return nil unless datadog_available?
active_trace = Datadog::Tracing.active_trace
return nil unless active_trace
active_trace.to_digest
end

def continue_trace_context(digest)
return unless datadog_available? && digest
Datadog::Tracing.continue_trace!(digest)
end

def datadog_available?
defined?(Datadog::Tracing) && defined?(Datadog::Tracing::TraceDigest)
end
end
end