Sidekiq Monitor

sidekiq_monitor.rb

namespace :sidekiq do
  desc 'Start Sidekiq and Monitor'
  task :start do
    trap('SIGTERM') { puts "Exiting processes"; exit }
    system "rake sidekiq:monitor & sidekiq"
  end

  desc 'Starts /health/monitor endpoint for sidekiq'
  task :monitor do
    require 'sidekiq/web'

    app = Sidekiq::Web
    app.get '/monitor/health' do
      content_type :json
      Sidekiq.dump_json(
        {
          status:   'OK',
          commit:   ENV['BUILD_COMMIT'],
          build:    ENV['BUILD_ID'],
          cluster:  ENV['CLUSTER']
        }
      )
    end

    # Logger
    ::Logger.class_eval { alias :write :'<<' }
    access_log = ::File.join(::File.dirname(::File.expand_path(__FILE__)),'..', '..', 'log','sidekiq_monitor.log')
    access_logger = ::Logger.new(access_log)
    error_logger = ::File.new(::File.join(::File.dirname(::File.expand_path(__FILE__)),'..', '..', 'log','sidekiq_monitor.log'),"a+")
    error_logger.sync = true

    app.configure do
      use ::Rack::CommonLogger, access_logger
    end

    app.before {
      env["rack.errors"] =  error_logger
    }

    # Settings
    app.set :logging, true
    app.set :environment, :production
    app.set :bind, '0.0.0.0'
    app.set :port, 9494
    puts "-- Sidekiq Monitor Starting"
    Process.daemon
    app.run!
  end
end