Contents

class Eye::Trigger::CheckDependency < Eye::Trigger
  param :names, [Array], true, 5

  def check(transition)
    check_dependency(transition.to_name) if transition.from_name == :up
  end

private

  def check_dependency(to)
    processes = names.map do |name|
      Eye::Control.find_nearest_process(name, process.group_name_pure, process.app_name)
    end.compact.select { |p| p.state_name != :unmonitored }
    return if processes.empty?
    processes = Eye::Utils::AliveArray.new(processes)

    act = case to
      when :down, :restarting; :restart
      when :stopping; :stop
      when :unmonitored; :unmonitor
    end

    if act
      processes.each do |p|
        p.schedule act, Eye::Reason.new(:"#{act} dependecies")
      end
    end
  end

end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
eye-0.8.pre2	lib/eye/trigger/check_dependency.rb
eye-0.8.pre	lib/eye/trigger/check_dependency.rb
eye-0.7	lib/eye/trigger/check_dependency.rb
eye-0.7.pre	lib/eye/trigger/check_dependency.rb