1 files changed, 53 insertions, 0 deletions
diff --git a/lib/gitlab/memory/watchdog/sidekiq_event_reporter.rb b/lib/gitlab/memory/watchdog/sidekiq_event_reporter.rb
new file mode 100644
index 00000000000..473ed1b8094
--- /dev/null
+++ b/lib/gitlab/memory/watchdog/sidekiq_event_reporter.rb
@@ -0,0 +1,53 @@
+# frozen_string_literal: true
+
+module Gitlab
+  module Memory
+    class Watchdog
+      class SidekiqEventReporter
+        include ::Gitlab::Utils::StrongMemoize
+
+        delegate :threshold_violated, :started, :stopped, :logger, to: :event_reporter
+
+        def initialize(logger: ::Sidekiq.logger)
+          @event_reporter = EventReporter.new(logger: logger)
+          @sidekiq_daemon_monitor = Gitlab::SidekiqDaemon::Monitor.instance
+          init_prometheus_metrics
+        end
+
+        def strikes_exceeded(monitor_name, labels = {})
+          running_jobs = fetch_running_jobs
+          labels[:running_jobs] = running_jobs
+          increment_worker_counters(running_jobs)
+
+          event_reporter.strikes_exceeded(monitor_name, labels)
+        end
+
+        private
+
+        attr_reader :event_reporter
+
+        def fetch_running_jobs
+          @sidekiq_daemon_monitor.jobs.map do |jid, job|
+            {
+              jid: jid,
+              worker_class: job[:worker_class].name
+            }
+          end
+        end
+
+        def increment_worker_counters(running_jobs)
+          running_jobs.each do |job|
+            @sidekiq_watchdog_running_jobs_counter.increment({ worker_class: job[:worker_class] })
+          end
+        end
+
+        def init_prometheus_metrics
+          @sidekiq_watchdog_running_jobs_counter = ::Gitlab::Metrics.counter(
+            :sidekiq_watchdog_running_jobs_total,
+            'Current running jobs when limit was reached'
+          )
+        end
+      end
+    end
+  end
+end