Class: GarbageMan::Rack::Middleware

Inherits:
Object
  • Object
show all
Defined in:
lib/garbageman/rack/middleware.rb

Constant Summary collapse

@@ok_response = 
[200, {'Content-Length' => '0'}, '']
@@gc_response = 
[589, {'Content-Length' => '0'}, '']

Instance Method Summary collapse

Constructor Details

#initialize(app) ⇒ Middleware

Returns a new instance of Middleware.



4
5
6
 
# File 'lib/garbageman/rack/middleware.rb', line 4

def initialize(app)
  @app = app
end

Instance Method Details

#call(env) ⇒ Object 



10
11
12
13
14
15
16
17
18
19
20
21
 
# File 'lib/garbageman/rack/middleware.rb', line 10

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