Sha256: e475792d0a70ec43fa01ebfe24f756078cbaafb662102672c46296a11794a8d9
Contents?: true
Size: 612 Bytes
Versions: 9
Compression:
Stored size: 612 Bytes
Contents
module PulseMeter
module Sensor
module Timelined
# Calculates min value in interval
class Min < Timeline
def aggregate_event(key, value)
redis.zadd(key, value, "#{value}::#{uniqid}")
redis.zremrangebyrank(key, 1, -1)
end
def summarize(key)
count = redis.zcard(key)
if count > 0
min_el = redis.zrange(key, 0, 0)[0]
redis.zscore(key, min_el)
else
nil
end
end
private
def deflate(value)
value.to_f
end
end
end
end
end
Version data entries
9 entries across 9 versions & 1 rubygems