class SSHKit::Runner::Group

Attributes

group_size[RW]

Public Class Methods

new(hosts, options = nil, &block) click to toggle source
Calls superclass method
# File lib/sshkit/runners/group.rb, line 8
def initialize(hosts, options = nil, &block)
  super(hosts, options, &block)
  @group_size = @options[:limit] || 2
end

Public Instance Methods

execute() click to toggle source
# File lib/sshkit/runners/group.rb, line 13
def execute
  hosts.each_slice(group_size).collect do |group_hosts|
    Parallel.new(group_hosts, &block).execute
    sleep wait_interval
  end.flatten
end