Sha256: ec3c2e04eb4f6894bf73b32541152d231472494b3cc809a08e1035db46d7304b
Contents?: true
Size: 732 Bytes
Versions: 18
Compression:
Stored size: 732 Bytes
Contents
# frozen_string_literal: true
module OpenTracing
module Instrumentation
module Bunny
# HeadersInjector inject tracing headers into bunny message headers
class HeadersInjector
# @param trace [OpenTracing::Tracer]
def initialize(tracer: OpenTracing.global_tracer)
@tracer = tracer
end
# inject tracing headers
# @param headers [Hash<String,String>]
# @param active_span [OpenTracing::Span]
def inject(
headers,
active_span: @tracer.active_span
)
@tracer.inject(
active_span.context,
OpenTracing::FORMAT_TEXT_MAP,
headers,
)
end
end
end
end
end
Version data entries
18 entries across 18 versions & 1 rubygems