Sha256: ffb75fe709ecdec1265ce435800e051743d197643e102e3b1c8d97a6d46f9ed7

Contents?: true

Size: 304 Bytes

Versions: 12

Compression:

Stored size: 304 Bytes

Contents

# frozen_string_literal: true

module Sbmt
  module KafkaProducer
    module Instrumentation
      class TracingMiddleware < ::WaterDrop::Middleware
        def initialize
          super

          append(OpenTelemetryTracer.new) if defined?(OpenTelemetryTracer)
        end
      end
    end
  end
end

Version data entries

12 entries across 12 versions & 1 rubygems

Version Path
sbmt-kafka_producer-3.2.2 lib/sbmt/kafka_producer/instrumentation/tracing_middleware.rb
sbmt-kafka_producer-3.2.1 lib/sbmt/kafka_producer/instrumentation/tracing_middleware.rb
sbmt-kafka_producer-3.2.0 lib/sbmt/kafka_producer/instrumentation/tracing_middleware.rb
sbmt-kafka_producer-3.1.1 lib/sbmt/kafka_producer/instrumentation/tracing_middleware.rb
sbmt-kafka_producer-3.1.0 lib/sbmt/kafka_producer/instrumentation/tracing_middleware.rb
sbmt-kafka_producer-3.0.0 lib/sbmt/kafka_producer/instrumentation/tracing_middleware.rb
sbmt-kafka_producer-2.2.3 lib/sbmt/kafka_producer/instrumentation/tracing_middleware.rb
sbmt-kafka_producer-2.2.2 lib/sbmt/kafka_producer/instrumentation/tracing_middleware.rb
sbmt-kafka_producer-2.2.1 lib/sbmt/kafka_producer/instrumentation/tracing_middleware.rb
sbmt-kafka_producer-2.2.0 lib/sbmt/kafka_producer/instrumentation/tracing_middleware.rb
sbmt-kafka_producer-2.1.0 lib/sbmt/kafka_producer/instrumentation/tracing_middleware.rb
sbmt-kafka_producer-2.0.0 lib/sbmt/kafka_producer/instrumentation/tracing_middleware.rb