Contents

module GarbageMan
  module Rack
    class Middleware
      def initialize(app)
        @app = app
      end

      @@ok_response = [200, {'Content-Length' => '0'}, '']
      @@gc_response = [589, {'Content-Length' => '0'}, '']
      def call(env)
        GarbageMan::Collector.instance.request_count += 1

        if env['REQUEST_PATH'] == GarbageMan::Config.gc_health_check_request_path
          GarbageMan::Collector.instance.healthy? ? @@ok_response : @@gc_response
        else
          # this is not 100% preventable with nginx, nginx will still send requests while waiting for the health check response
          GarbageMan::Collector.instance.logger.debug("still receiving traffic even though I'm waiting to GC") if GarbageMan::Collector.instance.will_collect
          GarbageMan::Collector.instance.select_next_server if GarbageMan::Collector::instance.will_select_next_server
          @app.call(env)
        end
      end
    end
  end
end

Version data entries

30 entries across 30 versions & 1 rubygems

Version	Path
garbageman-0.3.7	lib/garbageman/rack/middleware.rb
garbageman-0.3.6	lib/garbageman/rack/middleware.rb
garbageman-0.3.5	lib/garbageman/rack/middleware.rb
garbageman-0.3.4	lib/garbageman/rack/middleware.rb
garbageman-0.3.3	lib/garbageman/rack/middleware.rb
garbageman-0.3.2	lib/garbageman/rack/middleware.rb
garbageman-0.3.0	lib/garbageman/rack/middleware.rb
garbageman-0.2.9	lib/garbageman/rack/middleware.rb
garbageman-0.2.8	lib/garbageman/rack/middleware.rb
garbageman-0.2.7	lib/garbageman/rack/middleware.rb
garbageman-0.2.6	lib/garbageman/rack/middleware.rb
garbageman-0.2.4	lib/garbageman/rack/middleware.rb
garbageman-0.2.3	lib/garbageman/rack/middleware.rb
garbageman-0.2.2	lib/garbageman/rack/middleware.rb
garbageman-0.2.1	lib/garbageman/rack/middleware.rb
garbageman-0.2.0	lib/garbageman/rack/middleware.rb
garbageman-0.1.21	lib/garbageman/rack/middleware.rb
garbageman-0.1.20	lib/garbageman/rack/middleware.rb
garbageman-0.1.19	lib/garbageman/rack/middleware.rb
garbageman-0.1.18	lib/garbageman/rack/middleware.rb