Contents

require 'heroku-api'

module Delayed
  module Workless
    module Scaler

      class Heroku < Base

        extend Delayed::Workless::Scaler::HerokuClient

        def self.up
          client.put_workers(ENV['APP_NAME'], 1) if self.workers == 0
        end

        def self.down
          client.put_workers(ENV['APP_NAME'], 0) unless self.workers == 0 or self.jobs.count > 0
        end

        def self.workers
          client.get_ps(ENV['APP_NAME']).body.count { |p| p["process"] =~ /worker\.\d?/ }
        end

      end

    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
workless-1.1.2	lib/workless/scalers/heroku.rb
workless-1.1.1	lib/workless/scalers/heroku.rb
workless-1.1.0	lib/workless/scalers/heroku.rb