Contents

class TimeWindowDropCollector::Storage
  include TimeWindowDropCollector::Utils

  attr_reader :wrapper, :window, :slices

  def initialize( wrapper, window, slices )
    @wrapper = wrapper
    @window  = window
    @slices  = slices
  end

  def incr( keys, amount=1 )
    wrapper.incr( timestamp_key_multi( keys ), window, amount )
  end

  def count( keys )
    window_keys = window_keys_multi( keys )
    keys_values = wrapper.get( window_keys )

    grouping_count( keys_values )
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
time_window_drop_collector-0.3.1	lib/time_window_drop_collector/storage.rb