puma_capacity_to_cloudwatch.rb

module PumaCapacityToCloudwatch
  require 'puma_capacity_to_cloudwatch/utilization'
  require 'puma_capacity_to_cloudwatch/publish'

  class Error < StandardError; end

  def self.run
    sleep 10 # wait for puma to boot up
    return unless defined?(Puma)

    Thread.new do
      started_at = Time.current
      stats_samples = []
      loop do
        begin
          stats_samples << Utilization.new(Puma.stats).utilization
          if Time.current > (started_at + 1.minute)
            Publish.new(stats_samples).run
            started_at = Time.current
            stats_samples = []
          end
        end
        sleep 1
      end
    end
  end
end