Sha256: 8453e4f0fe51bb490818129a04d8371511a8efd280629d41eb89851fda2a9a74
Contents?: true
Size: 1.25 KB
Versions: 15
Compression:
Stored size: 1.25 KB
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 == nil || should_start)
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.new('stop transition because dependency is not up')
end
end
end
Version data entries
15 entries across 15 versions & 2 rubygems