Module: Karafka::Extensions::StdoutListener

Defined in:
lib/karafka/extensions/stdout_listener.rb

Overview

Additional methods for listener that listen on instrumentation related to the Sidekiq backend of Karafka

Instance Method Summary collapse

Instance Method Details

#on_backends_sidekiq_base_worker_perform(event) ⇒ Object

Logs ino about processing certain events with a given Sidekiq worker



19
20
21
22
23
24
 
# 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) ⇒ Object

Logs info about scheduling of a certain dataset with a Sidekiq backend



10
11
12
13
14
15
 
# 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