Sha256: 94c0f08f46ccb6d1d686b8d74fe62e7074c01eb712b6ded97b51ca91e364c8a2

Contents?: true

Size: 788 Bytes

Versions: 27

Compression:

Stored size: 788 Bytes

Contents

# frozen_string_literal: true

require_relative 'base'

module Karafka
  module Instrumentation
    module Vendors
      # Namespace for Appsignal instrumentation
      module Appsignal
        # Listener for reporting errors from both consumers and producers
        # Since we have the same API for WaterDrop and Karafka, we can use one listener with
        # independent instances
        class ErrorsListener < Base
          def_delegators :config, :client

          setting :client, default: Client.new

          configure

          # Sends error details to Appsignal
          #
          # @param event [Karafka::Core::Monitoring::Event]
          def on_error_occurred(event)
            client.send_error(event[:error])
          end
        end
      end
    end
  end
end

Version data entries

27 entries across 27 versions & 1 rubygems

Version Path
karafka-2.4.9 lib/karafka/instrumentation/vendors/appsignal/errors_listener.rb
karafka-2.4.8 lib/karafka/instrumentation/vendors/appsignal/errors_listener.rb
karafka-2.4.7 lib/karafka/instrumentation/vendors/appsignal/errors_listener.rb
karafka-2.4.6 lib/karafka/instrumentation/vendors/appsignal/errors_listener.rb
karafka-2.4.5 lib/karafka/instrumentation/vendors/appsignal/errors_listener.rb
karafka-2.4.4 lib/karafka/instrumentation/vendors/appsignal/errors_listener.rb
karafka-2.4.3 lib/karafka/instrumentation/vendors/appsignal/errors_listener.rb
karafka-2.4.0 lib/karafka/instrumentation/vendors/appsignal/errors_listener.rb
karafka-2.4.0.rc1 lib/karafka/instrumentation/vendors/appsignal/errors_listener.rb
karafka-2.3.4 lib/karafka/instrumentation/vendors/appsignal/errors_listener.rb
karafka-2.4.0.beta2 lib/karafka/instrumentation/vendors/appsignal/errors_listener.rb
karafka-2.4.0.beta1 lib/karafka/instrumentation/vendors/appsignal/errors_listener.rb
karafka-2.3.3 lib/karafka/instrumentation/vendors/appsignal/errors_listener.rb
karafka-2.3.2 lib/karafka/instrumentation/vendors/appsignal/errors_listener.rb
karafka-2.3.1 lib/karafka/instrumentation/vendors/appsignal/errors_listener.rb
karafka-2.3.0 lib/karafka/instrumentation/vendors/appsignal/errors_listener.rb
karafka-2.3.0.rc1 lib/karafka/instrumentation/vendors/appsignal/errors_listener.rb
karafka-2.3.0.alpha2 lib/karafka/instrumentation/vendors/appsignal/errors_listener.rb
karafka-2.3.0.alpha1 lib/karafka/instrumentation/vendors/appsignal/errors_listener.rb
karafka-2.2.14 lib/karafka/instrumentation/vendors/appsignal/errors_listener.rb