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
        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

6 entries across 6 versions & 1 rubygems

Version	Path
ironfan-6.0.6	lib/ironfan/broker.rb
ironfan-6.0.5	lib/ironfan/broker.rb
ironfan-6.0.4	lib/ironfan/broker.rb
ironfan-6.0.3	lib/ironfan/broker.rb
ironfan-6.0.1	lib/ironfan/broker.rb
ironfan-6.0.0	lib/ironfan/broker.rb