Sha256: 4751ae47b221c25da4f6ca89b78a8d3c62eb36ea56cfa5e48c6100510caf540e

Contents?: true

Size: 641 Bytes

Versions: 40

Compression:

Stored size: 641 Bytes

Contents

# frozen_string_literal: true

module Karafka
  # @note Since we can only have one statistics callbacks manager and one error callbacks manager
  # we use WaterDrops one that is already configured.
  module Instrumentation
    class << self
      # Returns a manager for statistics callbacks
      # @return [::WaterDrop::CallbacksManager]
      def statistics_callbacks
        ::WaterDrop::Instrumentation.statistics_callbacks
      end

      # Returns a manager for error callbacks
      # @return [::WaterDrop::CallbacksManager]
      def error_callbacks
        ::WaterDrop::Instrumentation.error_callbacks
      end
    end
  end
end

Version data entries

40 entries across 40 versions & 1 rubygems

Version Path
karafka-2.0.2 lib/karafka/instrumentation.rb
karafka-2.0.1 lib/karafka/instrumentation.rb
karafka-2.0.0 lib/karafka/instrumentation.rb
karafka-2.0.0.rc6 lib/karafka/instrumentation.rb
karafka-2.0.0.rc5 lib/karafka/instrumentation.rb
karafka-2.0.0.rc4 lib/karafka/instrumentation.rb
karafka-2.0.0.rc3 lib/karafka/instrumentation.rb
karafka-2.0.0.rc2 lib/karafka/instrumentation.rb
karafka-2.0.0.rc1 lib/karafka/instrumentation.rb
karafka-2.0.0.beta5 lib/karafka/instrumentation.rb
karafka-2.0.0.beta4 lib/karafka/instrumentation.rb
karafka-2.0.0.beta3 lib/karafka/instrumentation.rb
karafka-2.0.0.beta2 lib/karafka/instrumentation.rb
karafka-2.0.0.beta1 lib/karafka/instrumentation.rb
karafka-2.0.0.alpha6 lib/karafka/instrumentation.rb
karafka-2.0.0.alpha5 lib/karafka/instrumentation.rb
karafka-2.0.0.alpha4 lib/karafka/instrumentation.rb
karafka-2.0.0.alpha3 lib/karafka/instrumentation.rb
karafka-2.0.0.alpha2 lib/karafka/instrumentation.rb
karafka-2.0.0.alpha1 lib/karafka/instrumentation.rb