Sha256: 1b4ce20025938548d6ab212dc86772a1e96a44ffc6c7e658de70386bf49fde33

Contents?: true

Size: 374 Bytes

Versions: 31

Compression:

Stored size: 374 Bytes

Contents

module SSHKit

  module Runner

    class Group < Sequential
      attr_writer :group_size
      def execute
        hosts.each_slice(group_size).collect do |group_hosts|
          Parallel.new(group_hosts, &block).execute
          sleep wait_interval
        end.flatten
      end
      private
      def group_size
        @group_size ||= 2
      end
    end

  end

end

Version data entries

31 entries across 31 versions & 1 rubygems

Version Path
sshkit-1.2.0 lib/sshkit/runners/group.rb
sshkit-1.1.0 lib/sshkit/runners/group.rb
sshkit-1.0.0 lib/sshkit/runners/group.rb
sshkit-0.0.34 lib/sshkit/runners/group.rb
sshkit-0.0.33 lib/sshkit/runners/group.rb
sshkit-0.0.32 lib/sshkit/runners/group.rb
sshkit-0.0.31 lib/sshkit/runners/group.rb
sshkit-0.0.29 lib/sshkit/runners/group.rb
sshkit-0.0.28 lib/sshkit/runners/group.rb
sshkit-0.0.27 lib/sshkit/runners/group.rb
sshkit-0.0.26 lib/sshkit/runners/group.rb
sshkit-0.0.25 lib/sshkit/runners/group.rb
sshkit-0.0.24 lib/sshkit/runners/group.rb
sshkit-0.0.23 lib/sshkit/runners/group.rb
sshkit-0.0.22 lib/sshkit/runners/group.rb
sshkit-0.0.21 lib/sshkit/runners/group.rb
sshkit-0.0.19 lib/sshkit/runners/group.rb
sshkit-0.0.18 lib/sshkit/runners/group.rb
sshkit-0.0.16 lib/sshkit/runners/group.rb
sshkit-0.0.15 lib/sshkit/runners/group.rb