Skip to content

Commit

Permalink
Dependency inject logger
Browse files Browse the repository at this point in the history
  • Loading branch information
p committed Feb 18, 2025
1 parent cee1a62 commit 3ac85d8
Show file tree
Hide file tree
Showing 2 changed files with 10 additions and 6 deletions.
1 change: 1 addition & 0 deletions lib/datadog/tracing/component.rb
Original file line number Diff line number Diff line change
Expand Up @@ -49,6 +49,7 @@ def build_tracer(settings, agent_settings, logger:)
Tracing::Tracer.new(
default_service: settings.service,
enabled: settings.tracing.enabled,
logger: logger,
trace_flush: trace_flush,
sampler: sampler_delegator,
span_sampler: build_span_sampler(settings),
Expand Down
15 changes: 9 additions & 6 deletions lib/datadog/tracing/tracer.rb
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,8 @@ class Tracer
:provider,
:sampler,
:span_sampler,
:tags
:tags,
:logger

attr_accessor \
:default_service,
Expand All @@ -52,6 +53,7 @@ def initialize(
context_provider: DefaultContextProvider.new,
default_service: Core::Environment::Ext::FALLBACK_SERVICE_NAME,
enabled: true,
logger: Datadog.logger,
sampler: Sampling::PrioritySampler.new(
base_sampler: Sampling::AllSampler.new,
post_sampler: Sampling::RuleSampler.new
Expand All @@ -63,6 +65,7 @@ def initialize(
@trace_flush = trace_flush
@default_service = default_service
@enabled = enabled
@logger = logger
@provider = context_provider
@sampler = sampler
@span_sampler = span_sampler
Expand Down Expand Up @@ -146,7 +149,7 @@ def trace(
active_trace
end
rescue StandardError => e
Datadog.logger.debug { "Failed to trace: #{e}" }
logger.debug { "Failed to trace: #{e}" }

# Tracing failed: fallback and run code without tracing.
return skip_trace(name, &block)
Expand Down Expand Up @@ -268,7 +271,7 @@ def sample_trace(trace_op)
@sampler.sample!(trace_op)
rescue StandardError => e
SAMPLE_TRACE_LOG_ONLY_ONCE.run do
Datadog.logger.warn { "Failed to sample trace: #{e.class.name} #{e} at #{Array(e.backtrace).first}" }
logger.warn { "Failed to sample trace: #{e.class.name} #{e} at #{Array(e.backtrace).first}" }
end
end
end
Expand Down Expand Up @@ -488,7 +491,7 @@ def sample_span(trace_op, span)
@span_sampler.sample!(trace_op, span)
rescue StandardError => e
SAMPLE_SPAN_LOG_ONLY_ONCE.run do
Datadog.logger.warn { "Failed to sample span: #{e.class.name} #{e} at #{Array(e.backtrace).first}" }
logger.warn { "Failed to sample span: #{e.class.name} #{e} at #{Array(e.backtrace).first}" }
end
end
end
Expand All @@ -504,7 +507,7 @@ def flush_trace(trace_op)
write(trace) if trace && !trace.empty?
rescue StandardError => e
FLUSH_TRACE_LOG_ONLY_ONCE.run do
Datadog.logger.warn { "Failed to flush trace: #{e.class.name} #{e} at #{Array(e.backtrace).first}" }
logger.warn { "Failed to flush trace: #{e.class.name} #{e} at #{Array(e.backtrace).first}" }
end
end
end
Expand All @@ -518,7 +521,7 @@ def write(trace)
return unless trace && @writer

if Datadog.configuration.diagnostics.debug
Datadog.logger.debug { "Writing #{trace.length} spans (enabled: #{@enabled})\n#{trace.spans.pretty_inspect}" }
logger.debug { "Writing #{trace.length} spans (enabled: #{@enabled})\n#{trace.spans.pretty_inspect}" }
end

@writer.write(trace)
Expand Down

0 comments on commit 3ac85d8

Please sign in to comment.