Sha256: 3cf2cf6e6472ac45a0a34d8a69efe42e8a2b21cd1cbcbe655c4a6accdab4b733
Contents?: true
Size: 539 Bytes
Versions: 22
Compression:
Stored size: 539 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).to_f else nil end end end end end end
Version data entries
22 entries across 22 versions & 2 rubygems