Contents

require 'spectator/atomic_number'
require 'spectator/measure'

module Spectator
  # A counter is used to measure the rate at which an event is occurring
  class Counter
    # Initialize a new instance setting its id, and starting the
    # count at 0
    def initialize(id)
      @id = id
      @count = AtomicNumber.new(0)
    end

    # Increment the counter by delta
    def increment(delta = 1)
      @count.add_and_get(delta)
    end

    # Get the current count as a list of Measure and reset the count to 0
    def measure
      [Measure.new(@id.with_stat('count'), @count.get_and_set(0))]
    end

    # Read the current count. Calls to measure will reset it
    def count
      @count.get
    end

    # Get a string representation for debugging purposes
    def to_s
      "Counter{id=#{@id}, count=#{@count.get}}"
    end
  end
end

Version data entries

3 entries across 3 versions & 2 rubygems

Version	Path
netflix-spectator-rb-0.1.3	lib/spectator/counter.rb
netflix-spectator-rb-0.1.1	lib/spectator/counter.rb
spectator-rb-0.1.0	lib/spectator/counter.rb