Class: Karafka::Web::Tracking::Producers::Listeners::Errors

Inherits:
Base
  • Object
show all
Includes:
Helpers::ErrorInfo
Defined in:
lib/karafka/web/tracking/producers/listeners/errors.rb

Overview

Listener for tracking producers published errors

Instance Method Summary collapse

Methods included from Helpers::ErrorInfo

#extract_error_info, #extract_error_message

Instance Method Details

#on_error_occurred(event) ⇒ Object

Tracks any producer related errors

Parameters:

  • event (Karafka::Core::Monitoring::Event)


20
21
22
23
24
# File 'lib/karafka/web/tracking/producers/listeners/errors.rb', line 20

def on_error_occurred(event)
  track do |sampler|
    sampler.errors << build_error_details(event)
  end
end