Class: Bluepill::Triggers::Flapping
- Inherits:
-
Bluepill::Trigger
- Object
- Bluepill::Trigger
- Bluepill::Triggers::Flapping
- Defined in:
- lib/bluepill/triggers/flapping.rb
Constant Summary collapse
- TRIGGER_STATES =
[:starting, :restarting]
- PARAMS =
[:times, :within, :retry_in]
Instance Attribute Summary collapse
-
#timeline ⇒ Object
readonly
Returns the value of attribute timeline.
Attributes inherited from Bluepill::Trigger
#logger, #mutex, #process, #scheduled_events
Instance Method Summary collapse
- #check_flapping ⇒ Object
-
#initialize(process, options = {}) ⇒ Flapping
constructor
A new instance of Flapping.
- #notify(transition) ⇒ Object
- #reset! ⇒ Object
Methods inherited from Bluepill::Trigger
[], #cancel_all_events, #dispatch!, inherited, #schedule_event
Constructor Details
#initialize(process, options = {}) ⇒ Flapping
Returns a new instance of Flapping.
12 13 14 15 16 17 18 19 20 21 |
# File 'lib/bluepill/triggers/flapping.rb', line 12 def initialize(process, = {}) .reverse_merge!(:times => 5, :within => 1, :retry_in => 5) .each_pair do |name, val| instance_variable_set("@#{name}", val) if PARAMS.include?(name) end @timeline = Util::RotationalArray.new(@times) super end |
Instance Attribute Details
#timeline ⇒ Object (readonly)
Returns the value of attribute timeline.
10 11 12 |
# File 'lib/bluepill/triggers/flapping.rb', line 10 def timeline @timeline end |
Instance Method Details
#check_flapping ⇒ Object
35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 |
# File 'lib/bluepill/triggers/flapping.rb', line 35 def check_flapping # The process has not flapped if we haven't encountered enough incidents return unless (@timeline.compact.length == self.times) # Check if the incident happend within the timeframe duration = (@timeline.last - @timeline.first) <= self.within if duration self.logger.info "Flapping detected: retrying in #{self.retry_in} seconds" self.schedule_event(:start, self.retry_in) unless self.retry_in == 0 # retry_in zero means "do not retry, ever" self.schedule_event(:unmonitor, 0) @timeline.clear # This will prevent a transition from happening in the process state_machine throw :halt end end |
#notify(transition) ⇒ Object
23 24 25 26 27 28 |
# File 'lib/bluepill/triggers/flapping.rb', line 23 def notify(transition) if TRIGGER_STATES.include?(transition.to_name) self.timeline << Time.now.to_i self.check_flapping end end |
#reset! ⇒ Object
30 31 32 33 |
# File 'lib/bluepill/triggers/flapping.rb', line 30 def reset! @timeline.clear super end |