Contents

class Eye::Trigger::Flapping < Eye::Trigger

  # trigger :flapping, :times => 10, :within => 1.minute,
  #         :retry_in => 10.minutes, :retry_times => 15

  param :times, [Fixnum], true, 5
  param :within, [Float, Fixnum], true
  param :retry_in, [Float, Fixnum]
  param :retry_times, [Fixnum]

  def check(transition)
    on_flapping if transition.event == :crashed && !good?
  end

private

  def good?
    states = process.states_history.states_for_period( within, @last_at )
    down_count = states.count{|st| st == :down }

    if down_count >= times
      @last_at = process.states_history.last_state_changed_at
      false
    else
      true
    end
  end

  def on_flapping
    debug 'flapping recognized!!!'

    process.notify :error, 'flapping!'
    process.schedule :unmonitor, Eye::Reason.new(:flapping)

    return unless retry_in
    return if retry_times && process.flapping_times >= retry_times

    process.schedule_in(retry_in.to_f, :retry_start_after_flapping)
  end

end

Version data entries

12 entries across 12 versions & 3 rubygems

Version	Path
eye-0.6.2	lib/eye/trigger/flapping.rb
eye-0.6.2.pre	lib/eye/trigger/flapping.rb
ace-eye-0.6.5	lib/eye/trigger/flapping.rb
ace-eye-0.6.4	lib/eye/trigger/flapping.rb
eye-0.6.1	lib/eye/trigger/flapping.rb
ace-eye-0.6.3	lib/eye/trigger/flapping.rb
ace-eye-0.6.2	lib/eye/trigger/flapping.rb
ace-eye-0.6.1	lib/eye/trigger/flapping.rb
eye-0.6	lib/eye/trigger/flapping.rb
reel-eye-0.5.2.1	lib/eye/trigger/flapping.rb
reel-eye-0.5.2	lib/eye/trigger/flapping.rb
eye-0.5.2	lib/eye/trigger/flapping.rb