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

    processes = processes.compact.reject { |p| p.state_name == :unmonitored }
    return if processes.empty?
    processes = Eye::Utils::AliveArray.new(processes)

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

    if act
      processes.each do |p|
        p.schedule command: act, reason: "#{act} dependecies"
      end
    end
  end

end

Version data entries

7 entries across 7 versions & 1 rubygems

Version	Path
eye-0.10.1.pre	lib/eye/trigger/check_dependency.rb
eye-0.10.0	lib/eye/trigger/check_dependency.rb
eye-0.10.0.alpha2	lib/eye/trigger/check_dependency.rb
eye-0.10.0.alpha	lib/eye/trigger/check_dependency.rb
eye-0.9.4.nosigar	lib/eye/trigger/check_dependency.rb
eye-0.9.4	lib/eye/trigger/check_dependency.rb
eye-0.9.3	lib/eye/trigger/check_dependency.rb