Sha256: fe25fbfb397d1c4c9650010262a1a328854ce6424c64c934fe0dd1a3a9b733b8

Contents?: true

Size: 290 Bytes

Versions: 8

Compression:

Stored size: 290 Bytes

Contents

module Kafka
  class NullInstrumentation
    def self.instrument(name, payload = {})
      yield payload if block_given?
    end
  end

  if defined?(ActiveSupport::Notifications)
    Instrumentation = ActiveSupport::Notifications
  else
    Instrumentation = NullInstrumentation
  end
end

Version data entries

8 entries across 8 versions & 1 rubygems

Version Path
ruby-kafka-0.3.2 lib/kafka/instrumentation.rb
ruby-kafka-0.3.1 lib/kafka/instrumentation.rb
ruby-kafka-0.3.0 lib/kafka/instrumentation.rb
ruby-kafka-0.2.0 lib/kafka/instrumentation.rb
ruby-kafka-0.1.7 lib/kafka/instrumentation.rb
ruby-kafka-0.1.6 lib/kafka/instrumentation.rb
ruby-kafka-0.1.5 lib/kafka/instrumentation.rb
ruby-kafka-0.1.4 lib/kafka/instrumentation.rb