Contents

class Eye::Trigger::WaitDependency < Eye::Trigger

  param :names, [Array], true
  param :wait_timeout, [Numeric], nil, 15.seconds
  param :retry_after, [Numeric], nil, 1.minute
  param :should_start, [TrueClass, FalseClass]

  def check(transition)
    wait_dependency if transition.to_name == :starting
  end

private

  def wait_dependency
    processes = names.map do |name|
      Eye::Control.find_nearest_process(name, process.group_name_pure, process.app_name)
    end.compact
    return if processes.empty?
    processes = Eye::Utils::AliveArray.new(processes)

    processes.each do |p|
      if p.state_name != :up && (should_start != false)
        p.schedule :start, Eye::Reason.new(:start_dependency)
      end
    end

    res = true

    processes.pmap do |p|
      name = p.name

      res &= process.wait_for_condition(wait_timeout, 0.5) do
        info "wait for #{name} until it :up"
        p.state_name == :up
      end
    end

    unless res
      warn "not waited for #{names} to be up"
      process.switch :unmonitoring

      if retry_after
        process.schedule_in retry_after, :start, Eye::Reason.new(:wait_dependency)
      end

      raise Eye::Process::StateError, 'stop transition because dependency is not up'
    end
  end

end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
eye-0.8.1	lib/eye/trigger/wait_dependency.rb
eye-0.8.celluloid15	lib/eye/trigger/wait_dependency.rb
eye-0.8	lib/eye/trigger/wait_dependency.rb
eye-0.8.rc	lib/eye/trigger/wait_dependency.rb