lib/instrumental/event_aggregator.rb in instrumental_agent-3.0.0.beta2 vs lib/instrumental/event_aggregator.rb in instrumental_agent-3.0.0.beta3

@@ -1,26 +1,28 @@
-class EventAggregator
-  attr_accessor :counts, :values, :received_at, :frequency
- 
-  def initialize(frequency:)
-    @values = Hash.new
-    @frequency = frequency
-  end
+module Instrumental
+  class EventAggregator
+    attr_accessor :counts, :values, :received_at, :frequency
 
-  def put(command)
-    command_at = command.time
-    unless(command_at % frequency == 0)
-      command.time = (command_at - (command_at % frequency))
+    def initialize(frequency:)
+      @values = Hash.new
+      @frequency = frequency
     end
-    metadata = command.metadata
-    @values[metadata] = (command + @values[metadata])
-  end
 
-  def size
-    @values.size
-  end
+    def put(command)
+      command_at = command.time
+      unless(command_at % frequency == 0)
+        command.time = (command_at - (command_at % frequency))
+      end
+      metadata = command.metadata
+      @values[metadata] = (command + @values[metadata])
+    end
 
-  def coerce_time(time)
-    itime = time.to_i
-    (itime - (itime % frequency)).to_i
+    def size
+      @values.size
+    end
+
+    def coerce_time(time)
+      itime = time.to_i
+      (itime - (itime % frequency)).to_i
+    end
   end
 end