Contents

require_relative './helpers'

module Rstatsd
  class Collector < EventMachine::Connection
    include Rstatsd::Helpers

    def initialize
      super
    end

    def post_init
    end

    def receive_data(data)
      bits = data.split(':')
      key = format_key(bits.first)

      fields = bits.last.split("|")
      case fields[1]
      when 'c'
        if fields[0] == '1'
          value = redis.incr(key) 
          redis.rpush(counter_key_name(key), "#{value}:#{Time.now.to_i}")
        elsif fields[0] == '-1'
          value = redis.decr(key)
          redis.rpush(counter_key_name(key), "#{value}:#{Time.now.to_i}")
        end
        redis.ltrim(counter_key_name(key), -10000, -1)
      when 'ms'
        #update timer
        redis.rpush(timer_key_name(key), "#{fields[0]}:#{Time.now.to_i}")
        redis.ltrim(timer_key_name(key), -10000, -1)
      else
        # invalid update
      end
    end

    def unbind
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
rstatsd-0.3	lib/rstatsd/collector.rb