Contents

module God
  module Behaviors
    
    class NotifyWhenFlapping < Behavior
      attr_accessor :failures # number of failures 
      attr_accessor :seconds  # number of seconds
      attr_accessor :notifier # class to notify with
      
      def initialize
        super
        @startup_times = []
      end
      
      def valid?
        valid = true
        valid &= complain("You must specify the 'failures' attribute for :notify_when_flapping") unless self.failures
        valid &= complain("You must specify the 'seconds' attribute for :notify_when_flapping") unless self.seconds
        valid &= complain("You must specify the 'notifier' attribute for :notify_when_flapping") unless self.notifier
                
        # Must take one arg or variable args
        unless self.notifier.respond_to?(:notify) and [1,-1].include?(self.notifier.method(:notify).arity)
          valid &= complain("The 'notifier' must have a method 'notify' which takes 1 or variable args")
        end
        
        valid
      end
  
      def before_start
        now = Time.now.to_i
        @startup_times << now
        check_for_flapping(now)
      end
      
      def before_restart
        now = Time.now.to_i
        @startup_times << now
        check_for_flapping(now)
      end
      
      private
        
        def check_for_flapping(now)
          @startup_times.select! {|time| time >= now - self.seconds }
          if @startup_times.length >= self.failures
            self.notifier.notify("#{self.watch.name} has called start/restart #{@startup_times.length} times in #{self.seconds} seconds")
          end
        end
    end
  
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
god-0.4.0	lib/god/behaviors/notify_when_flapping.rb
god-0.4.1	lib/god/behaviors/notify_when_flapping.rb
god-0.4.3	lib/god/behaviors/notify_when_flapping.rb