Sha256: 50fc7bf3f5eb0d1d3d63a03d95940c84c86c7d7c9da73d771a85fc8235eaa1b1
Contents?: true
Size: 612 Bytes
Versions: 8
Compression:
Stored size: 612 Bytes
Contents
module Harness
class ResqueQueue
class SendGauge < Job
@queue = :metrics
def self.perform(attributes)
gauge = Gauge.new attributes
new.log gauge
end
end
class SendCounter < Job
@queue = :metrics
def self.perform(attributes)
counter = Counter.new attributes
new.log counter
end
end
def push(measurement)
if measurement.is_a? Gauge
Resque.enqueue SendGauge, measurement.attributes
elsif measurement.is_a? Counter
Resque.enqueue SendCounter, measurement.attributes
end
end
end
end
Version data entries
8 entries across 8 versions & 1 rubygems