Sha256: 95068224e8f08994d035fcd0509a201e8f869468482f309090314b4a15ec8716
Contents?: true
Size: 1.86 KB
Versions: 29
Compression:
Stored size: 1.86 KB
Contents
# frozen_string_literal: true
module Bolt
class ResultSet
attr_reader :results
include Enumerable
# We only want want to include these when puppet is loaded
def self.include_iterable
include(Puppet::Pops::Types::Iterable)
include(Puppet::Pops::Types::IteratorProducer)
end
def iterator
if Object.const_defined?(:Puppet) && Puppet.const_defined?(:Pops) &&
self.class.included_modules.include?(Puppet::Pops::Types::Iterable)
Puppet::Pops::Types::Iterable.on(@results, Bolt::Result)
else
raise NotImplementedError, "iterator requires puppet code to be loaded."
end
end
def initialize(results)
@results = results
end
def each
@results.each { |r| yield r }
self
end
def result_hash
@result_hash ||= @results.each_with_object({}) do |result, acc|
acc[result.target.name] = result
end
end
def count
@results.size
end
alias length count
alias size count
def empty
@results.empty?
end
alias empty? empty
def targets
results.map(&:target)
end
def names
@results.map { |r| r.target.name }
end
def ok
@results.all?(&:ok?)
end
alias ok? ok
def error_set
filtered = @results.reject(&:ok?)
ResultSet.new(filtered)
end
def ok_set
filtered = @results.select(&:success?)
self.class.new(filtered)
end
def find(target_name)
result_hash[target_name]
end
def first
@results.first
end
def eql?(other)
self.class == other.class && @results == other.results
end
def to_a
@results.map(&:status_hash)
end
def to_json(opts = nil)
@results.map(&:status_hash).to_json(opts)
end
def to_s
to_json
end
def ==(other)
eql?(other)
end
end
end
Version data entries
29 entries across 29 versions & 1 rubygems