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