Contents

module PoolParty
    
  class Pool < Base
    attr_accessor :verbose, :very_verbose, :debugging, :very_debugging, :auto_execute
    
    def cloud(name, &block)
      clouds[name.to_s] = Cloud.new(name.to_s, {:parent => self}, &block)
    end
    
    def clouds
      @clouds ||= {}
    end
    
    # Run command/s on all nodes in the pool.
    # Returns a hash in the form of {cloud => [{instance_id=>result}]}
    def cmd(commands, opts={})
      results = {}
      threads = clouds.collect do |name, c|
        Thread.new{ results[ name ] = c.cmd(commands, opts) }
      end
      threads.each{ |aThread| aThread.join }
      results
    end
        
    at_exit do
      if pool.auto_execute
        puts <<-EOE
----> Running #{pool.name} #{pool.auto_execute}
        EOE
        pool.run
      end
    end
    
    def run
      clouds.each do |cloud_name, cld|
        puts "----> Starting to build cloud #{cloud_name}"
        cld.run
      end
    end
  end

end

Version data entries

12 entries across 12 versions & 1 rubygems

Version	Path
poolparty-1.6.8	lib/poolparty/pool.rb
poolparty-1.6.7	lib/poolparty/pool.rb
poolparty-1.6.6	lib/poolparty/pool.rb
poolparty-1.6.5	lib/poolparty/pool.rb
poolparty-1.6.4	lib/poolparty/pool.rb
poolparty-1.6.3	lib/poolparty/pool.rb
poolparty-1.6.2	lib/poolparty/pool.rb
poolparty-1.6.1	lib/poolparty/pool.rb
poolparty-1.6.0	lib/poolparty/pool.rb
poolparty-1.5.0	lib/poolparty/pool.rb
poolparty-1.4.8	lib/poolparty/pool.rb
poolparty-1.4.7	lib/poolparty/pool.rb