Contents

# frozen_string_literal: true

require 'rails_autoscale_agent/store'
require 'rails_autoscale_agent/reporter'
require 'rails_autoscale_agent/config'
require 'rails_autoscale_agent/request'

module RailsAutoscaleAgent
  class Middleware
    def initialize(app)
      @app = app
    end

    def call(env)
      config = Config.instance
      request = Request.new(env, config)

      store = Store.instance
      Reporter.start(config, store)

      if !request.ignore? && queue_time = request.queue_time
        # NOTE: Expose queue time to the app
        env['queue_time'] = queue_time
        store.push queue_time
      end

      @app.call(env)
    end

  end
end

Version data entries

14 entries across 14 versions & 1 rubygems

Version	Path
rails_autoscale_agent-0.12.0	lib/rails_autoscale_agent/middleware.rb
rails_autoscale_agent-0.11.0	lib/rails_autoscale_agent/middleware.rb
rails_autoscale_agent-0.10.2	lib/rails_autoscale_agent/middleware.rb
rails_autoscale_agent-0.10.1	lib/rails_autoscale_agent/middleware.rb
rails_autoscale_agent-0.9.1	lib/rails_autoscale_agent/middleware.rb
rails_autoscale_agent-0.9.0	lib/rails_autoscale_agent/middleware.rb
rails_autoscale_agent-0.9.0.beta.5	lib/rails_autoscale_agent/middleware.rb
rails_autoscale_agent-0.9.0.beta.4	lib/rails_autoscale_agent/middleware.rb
rails_autoscale_agent-0.9.0.beta.2	lib/rails_autoscale_agent/middleware.rb
rails_autoscale_agent-0.8.3	lib/rails_autoscale_agent/middleware.rb
rails_autoscale_agent-0.8.2	lib/rails_autoscale_agent/middleware.rb
rails_autoscale_agent-0.9.0.beta.1	lib/rails_autoscale_agent/middleware.rb
rails_autoscale_agent-0.8.1	lib/rails_autoscale_agent/middleware.rb
rails_autoscale_agent-0.8.0	lib/rails_autoscale_agent/middleware.rb