Contents

module SnowmanIO
  module Loop
    class Main
      include Celluloid

      def initialize
        after(1) { tick }
      end

      def tick
        perform
        after(3) { tick }
      end

      private

      def perform
        App.time "Aggregation Time" do
          Aggregate.metrics_aggregate_5min
          Aggregate.metrics_aggregate_hour
          Aggregate.metrics_aggregate_daily
          Aggregate.metrics_clean_old
        end
      end
    end
  end
end

Version data entries

6 entries across 6 versions & 1 rubygems

Version	Path
snowman-io-0.5.1	lib/snowman-io/loop/main.rb
snowman-io-0.5.0	lib/snowman-io/loop/main.rb
snowman-io-0.4.0	lib/snowman-io/loop/main.rb
snowman-io-0.3.1	lib/snowman-io/loop/main.rb
snowman-io-0.3.0	lib/snowman-io/loop/main.rb
snowman-io-0.2.0	lib/snowman-io/loop/main.rb