Sha256: 62fe1f2524a370a9ec2bbb301d0c99b3f8c283ddfbd6f643d19d1c7e7cc522ea
Contents?: true
Size: 793 Bytes
Versions: 18
Compression:
Stored size: 793 Bytes
Contents
# Static counter
module PulseMeter
module Sensor
class Counter < Base
# Cleans up all sensor metadata in Redis
def cleanup
redis.del(value_key)
super
end
# Increments counter value by 1
def incr
event(1)
end
# Gets counter value
# @return [Fixnum]
def value
redis.get(value_key).to_i
end
# Gets redis key by which counter value is stored
# @return [String]
def value_key
@value_key ||= "pulse_meter:value:#{name}"
end
private
# Processes event by incremnting counter by given value
# @param value [Fixnum] increment
def process_event(value)
command_aggregator.incrby(value_key, value.to_i)
end
end
end
end
Version data entries
18 entries across 18 versions & 2 rubygems