Sha256: 4a90072106683ba3646a79e0595358c78827ee07fccadba6638001afc6d9eec9
Contents?: true
Size: 1.04 KB
Versions: 12
Compression:
Stored size: 1.04 KB
Contents
# frozen_string_literal: true
require "active_support/subscriber"
require "active_support/core_ext/object/try"
module SidekiqPublisher
module MetricsReporter
class Subscriber < ActiveSupport::Subscriber
private
def count(metric, value)
SidekiqPublisher.metrics_reporter&.try(:count, metric, value) unless value.nil?
end
end
class PublisherSubscriber < Subscriber
def enqueue_batch(event)
count("sidekiq_publisher.published", event.payload[:published_count])
end
attach_to "publisher.sidekiq_publisher"
end
class JobSubscriber < Subscriber
def purge(event)
count("sidekiq_publisher.purged", event.payload[:purged_count])
end
attach_to "job.sidekiq_publisher"
end
class UnpublishedSubscriber < Subscriber
def unpublished(event)
SidekiqPublisher.metrics_reporter&.
try(:gauge, "sidekiq_publisher.unpublished_count", event.payload[:unpublished_count])
end
attach_to "reporter.sidekiq_publisher"
end
end
end
Version data entries
12 entries across 12 versions & 1 rubygems