Sha256: aeec9c17a9bdd558e9d9a420befde3c04d5c5e48627df20f9e30be22fd32d818
Contents?: true
Size: 1.74 KB
Versions: 10
Compression:
Stored size: 1.74 KB
Contents
# This module is intended to read in a cluster DSL description, and broker
# out to the various cloud providers, to control instance life-cycle and
# handle provider-specific amenities (SecurityGroup, Volume, etc.) for
# them.
module Ironfan
def self.broker
@@broker ||= Ironfan::Broker.new
end
class Broker < Builder
# Take in a Dsl::Cluster; return Computers populated with all discovered
# resources that correlate; computers corresponding to partial or
# unrecognizable resources are labeled as bogus.
def discover!(clusters, with_cloud = true)
# Get fully resolved servers, and build Computers using them
computers = Computers.new(clusters: Array(clusters))
#
if with_cloud
providers = computers.map{|c| c.providers.values }.flatten.uniq
providers.each do |p|
p.forget!
end
Ironfan.parallel(providers) do |provider|
clusters.each do |cluster|
Ironfan.step cluster.name, "Loading #{provider.handle}", :cyan
provider.load cluster
end
end
#
clusters.each do |cluster|
Ironfan.step cluster.name, "Reconciling DSL and provider information", :cyan
end
computers.correlate
computers.validate
end
#
computers
end
def display(computers,style)
defined_data = computers.map do |mach|
hsh = mach.to_display(style)
hsh.merge!(yield(mach)) if block_given?
hsh
end
if defined_data.empty?
ui.info "Nothing to report"
else
headings = defined_data.map{|hsh| hsh.keys }.flatten.uniq
Formatador.display_compact_table(defined_data, headings.to_a)
end
end
end
end
Version data entries
10 entries across 10 versions & 1 rubygems