class OpenTelemetry::Instrumentation::RubyKafka::Instrumentation
The Instrumentation
class contains logic to detect and install the KafkaRuby instrumentation
Constants
- MINIMUM_VERSION
Private Instance Methods
gem_version()
click to toggle source
# File lib/opentelemetry/instrumentation/ruby_kafka/instrumentation.rb, line 30 def gem_version Gem.loaded_specs['ruby-kafka']&.version || Gem::Version.new(Kafka::VERSION) end
patch()
click to toggle source
# File lib/opentelemetry/instrumentation/ruby_kafka/instrumentation.rb, line 40 def patch ::Kafka::Producer.prepend(Patches::Producer) ::Kafka::Consumer.prepend(Patches::Consumer) ::Kafka::Client.prepend(Patches::Client) end
require_patches()
click to toggle source
# File lib/opentelemetry/instrumentation/ruby_kafka/instrumentation.rb, line 34 def require_patches require_relative 'patches/producer' require_relative 'patches/consumer' require_relative 'patches/client' end