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

Defined in:
lib/datadog/tracing/contrib/karafka.rb,
lib/datadog/tracing/contrib/karafka/ext.rb,
lib/datadog/tracing/contrib/karafka/monitor.rb,
lib/datadog/tracing/contrib/karafka/patcher.rb,
lib/datadog/tracing/contrib/karafka/framework.rb,
lib/datadog/tracing/contrib/karafka/integration.rb,
lib/datadog/tracing/contrib/karafka/configuration/settings.rb,
lib/datadog/tracing/contrib/karafka/distributed/propagation.rb,
sig/datadog/tracing/contrib/karafka.rbs,
sig/datadog/tracing/contrib/karafka/ext.rbs,
sig/datadog/tracing/contrib/karafka/monitor.rbs,
sig/datadog/tracing/contrib/karafka/patcher.rbs,
sig/datadog/tracing/contrib/karafka/framework.rbs,
sig/datadog/tracing/contrib/karafka/integration.rbs,
sig/datadog/tracing/contrib/karafka/configuration/settings.rbs,
sig/datadog/tracing/contrib/karafka/distributed/propagation.rbs

Overview

Karafka integration public API

Defined Under Namespace

Modules: Configuration

Class Method Summary collapse

Class Method Details

.extract(data) ⇒ TraceDigest?

Parameters:

  • data (Hash[untyped, untyped])

Returns:



18
19
20
21
22
 
# File 'lib/datadog/tracing/contrib/karafka.rb', line 18

def self.extract(data)
  raise 'Please invoke Datadog.configure at least once before calling this method' unless @propagation

  @propagation.extract(data)
end

.inject(digest, data) ⇒ void

This method returns an undefined value.

Parameters:



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

def self.inject(digest, data)
  raise 'Please invoke Datadog.configure at least once before calling this method' unless @propagation

  @propagation.inject!(digest, data)
end