Module: Delayed::Workless::Scaler
- Defined in:
- lib/workless/scaler.rb,
lib/workless/scalers/base.rb,
lib/workless/scalers/null.rb,
lib/workless/scalers/local.rb,
lib/workless/scalers/heroku.rb,
lib/workless/scalers/heroku_cedar.rb
Defined Under Namespace
Modules: ClassMethods, HerokuClient Classes: Base, Heroku, HerokuCedar, Local, Null
Class Method Summary collapse
Class Method Details
.included(base) ⇒ Object
10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 |
# File 'lib/workless/scaler.rb', line 10 def self.included(base) base.send :extend, ClassMethods if base.to_s =~ /ActiveRecord/ base.class_eval do after_commit "self.class.scaler.down", :on => [:destroy, :update], :if => Proc.new {|r| r.destroyed? or !r.failed_at.nil? } after_commit "self.class.scaler.up", :on => :create end elsif base.to_s =~ /Sequel/ base.send(:define_method, 'after_destroy') do super self.class.scaler.down end base.send(:define_method, 'after_create') do super self.class.scaler.up end base.send(:define_method, 'after_update') do super self.class.scaler.down end else base.class_eval do after_destroy "self.class.scaler.down" after_create "self.class.scaler.up" after_update "self.class.scaler.down", :unless => Proc.new {|r| r.failed_at.nil? } end end end |