Sha256: c4a1c143c88a10292fccfe493c6ee3f3448ac40da441770e6a1bc55dfbe12101

Contents?: true

Size: 873 Bytes

Versions: 6

Compression:

Stored size: 873 Bytes

Contents

module LogStashLogger
  module Device
    class Balancer < Base
      attr_reader :devices

      def initialize(opts)
        @io = self
        @devices = create_devices(opts[:outputs])
        self.class.delegate_to_all(:close, :flush)
        self.class.delegate_to_one(:write)
      end

      private

      def create_devices(opts)
        opts.map { |device_opts| Device.new(device_opts) }
      end

      def self.delegate_to_all(*methods)
        methods.each do |m|
          define_method(m) do |*args|
            devices.each { |device| device.send(m, *args) }
          end
        end
      end

      def self.delegate_to_one(*methods)
        methods.each do |m|
          define_method(m) do |*args|
            select_device.send(m, *args)
          end
        end
      end

      def select_device
        devices.sample
      end
    end
  end
end

Version data entries

6 entries across 6 versions & 1 rubygems

Version Path
logstash-logger-0.15.2 lib/logstash-logger/device/balancer.rb
logstash-logger-0.15.1 lib/logstash-logger/device/balancer.rb
logstash-logger-0.15.0 lib/logstash-logger/device/balancer.rb
logstash-logger-0.14.1 lib/logstash-logger/device/balancer.rb
logstash-logger-0.14.0 lib/logstash-logger/device/balancer.rb
logstash-logger-0.13.0 lib/logstash-logger/device/balancer.rb