Module: Datadog::Tracing::Contrib::Karafka::Framework

Defined in:
lib/datadog/tracing/contrib/karafka/framework.rb

Overview

Karafka framework code, used to essentially:

  • handle configuration entries which are specific to Datadog tracing

  • instrument parts of the framework when needed

Class Method Summary collapse

Class Method Details

.activate_waterdrop!(datadog_config, karafka_config) ⇒ Object

Apply relevant configuration from Karafka to WaterDrop



19
20
21
22
23
24
25
 
# File 'lib/datadog/tracing/contrib/karafka/framework.rb', line 19

def self.activate_waterdrop!(datadog_config, karafka_config)
  datadog_config.tracing.instrument(
    :waterdrop,
    service_name: karafka_config[:service_name],
    distributed_tracing: karafka_config[:distributed_tracing],
  )
end

.setup ⇒ Object 



11
12
13
14
15
16
 
# File 'lib/datadog/tracing/contrib/karafka/framework.rb', line 11

def self.setup
  Datadog.configure do |datadog_config|
    karafka_config = datadog_config.tracing[:karafka]
    activate_waterdrop!(datadog_config, karafka_config)
  end
end