Class: Datadog::Tracing::Contrib::Karafka::Integration

Inherits:

Object

• Object
• Datadog::Tracing::Contrib::Karafka::Integration

Includes:

Integration

Defined in:

lib/datadog/tracing/contrib/karafka/integration.rb

Overview

Description of Kafka integration

Constant Summary

MINIMUM_VERSION =

Minimum version of the Karafka library that we support karafka.io/docs/Versions-Lifecycle-and-EOL/#versioning-strategy

Gem::Version.new('2.3.0')

Class Method Summary

• .compatible? ⇒ Boolean
• .loaded? ⇒ Boolean
• .version ⇒ Object

Instance Method Summary

• #new_configuration ⇒ Object
• #patcher ⇒ Object

Methods included from Integration

included

Class Method Details

.compatible? ⇒ Boolean

Returns:

• (Boolean)

# File 'lib/datadog/tracing/contrib/karafka/integration.rb', line 30

def self.compatible?
  super && version >= MINIMUM_VERSION
end

.loaded? ⇒ Boolean

Returns:

• (Boolean)

# File 'lib/datadog/tracing/contrib/karafka/integration.rb', line 26

def self.loaded?
  !defined?(::Karafka).nil?
end

.version ⇒ Object

# File 'lib/datadog/tracing/contrib/karafka/integration.rb', line 22

def self.version
  Gem.loaded_specs['karafka']&.version
end

Instance Method Details

#new_configuration ⇒ Object

# File 'lib/datadog/tracing/contrib/karafka/integration.rb', line 34

def new_configuration
  Configuration::Settings.new
end

#patcher ⇒ Object

# File 'lib/datadog/tracing/contrib/karafka/integration.rb', line 38

def patcher
  Patcher
end