vendor/supply_drop/lib/supply_drop/writer/batched.rb


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

module SupplyDrop
  module Writer
    class Batched
      def initialize(logger)
        @outputs = {}
        @logger = logger
      end

      def collect_output(host, data)
        @outputs[host] ||= ""
        @outputs[host] << data
      end

      def all_output_collected
        @outputs.keys.sort.each do |host|
          @logger.info "Puppet output for #{host}"
          @logger.debug @outputs[host], host
        end
      end
    end
  end
end