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

Version Path
pulse-meter-0.2.3 lib/pulse-meter/sensor/timelined/min.rb
pulse-meter-0.2.2 lib/pulse-meter/sensor/timelined/min.rb
pulse-meter-0.2.1 lib/pulse-meter/sensor/timelined/min.rb
pulse-meter-0.2.0 lib/pulse-meter/sensor/timelined/min.rb
pulse-meter-client-backport-0.1.4 lib/pulse-meter/sensor/timelined/min.rb
pulse-meter-0.1.11 lib/pulse-meter/sensor/timelined/min.rb
pulse-meter-client-backport-0.1.3 lib/pulse-meter/sensor/timelined/min.rb
pulse-meter-0.1.10 lib/pulse-meter/sensor/timelined/min.rb
pulse-meter-client-backport-0.1.2 lib/pulse-meter/sensor/timelined/min.rb
pulse-meter-0.1.9 lib/pulse-meter/sensor/timelined/min.rb
pulse-meter-client-backport-0.1.1 lib/pulse-meter/sensor/timelined/min.rb
pulse-meter-0.1.8 lib/pulse-meter/sensor/timelined/min.rb
pulse-meter-0.1.7 lib/pulse-meter/sensor/timelined/min.rb
pulse-meter-0.1.6 lib/pulse-meter/sensor/timelined/min.rb
pulse-meter-0.1.5 lib/pulse-meter/sensor/timelined/min.rb
pulse-meter-0.1.4 lib/pulse-meter/sensor/timelined/min.rb
pulse-meter-0.1.3 lib/pulse-meter/sensor/timelined/min.rb
pulse-meter-0.1.2 lib/pulse-meter/sensor/timelined/min.rb
pulse-meter-0.1.1 lib/pulse-meter/sensor/timelined/min.rb
pulse-meter-client-backport-0.1.0 lib/pulse-meter/sensor/timelined/min.rb