module Karafka::Extensions::StdoutListener
Additional methods for listener that listen on instrumentation related to the Sidekiq backend of Karafka
Public Instance Methods
on_backends_sidekiq_base_worker_perform(event)
click to toggle source
Logs ino about processing certain events with a given Sidekiq worker @param event [Dry::Events::Event] event details including payload
# File lib/karafka/extensions/stdout_listener.rb, line 19 def on_backends_sidekiq_base_worker_perform(event) count = event[:consumer].send(:params_batch).size topic = event[:consumer].topic.name time = event[:time] info "Sidekiq processing of topic #{topic} with #{count} messages took #{time} ms" end
on_backends_sidekiq_process(event)
click to toggle source
Logs info about scheduling of a certain dataset with a Sidekiq backend @param event [Dry::Events::Event] event details including payload
# File lib/karafka/extensions/stdout_listener.rb, line 10 def on_backends_sidekiq_process(event) count = event[:caller].send(:params_batch).size topic = event[:caller].topic.name time = event[:time] info "Scheduling of #{count} messages to Sidekiq on topic #{topic} took #{time} ms" end