lib/karafka-sidekiq-backend.rb in karafka-sidekiq-backend-1.1.0 vs lib/karafka-sidekiq-backend.rb in karafka-sidekiq-backend-1.2.0.beta1
- old
+ new
@@ -25,5 +25,10 @@
end
# Uses Karafka loader to load all the sources that this backend needs
Karafka::Loader.load!(Karafka::Backends::Sidekiq.core_root)
Karafka::AttributesMap.prepend(Karafka::Extensions::SidekiqAttributesMap)
+# Register internal events for instrumentation
+%w[
+ backends.sidekiq.process
+ backends.sidekiq.base_worker.perform
+].each(&Karafka.monitor.method(:register_event))