Sha256: 86b8289fc94b01598ed805a7fcb0264f05d9418bc4b8573ca40bb02d73c49657
Contents?: true
Size: 608 Bytes
Versions: 16
Compression:
Stored size: 608 Bytes
Contents
module Harness
class SidekiqQueue
class SendGauge < Job
include Sidekiq::Worker
def perform(attributes)
gauge = Gauge.new attributes
log gauge
end
end
class SendCounter < Job
include Sidekiq::Worker
def perform(attributes)
counter = Counter.new attributes
log counter
end
end
def self.push(measurement)
if measurement.is_a? Gauge
SendGauge.perform_async measurement.attributes
elsif measurement.is_a? Counter
SendCounter.perform_async measurement.attributes
end
end
end
end
Version data entries
16 entries across 16 versions & 1 rubygems