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