Contents

require 'pit'

module Fluent::Config::Pit
  def self.extract(conf)
    pit = Pit.get(conf.arg)
    ex = Fluent::Config::Element.new('', '', conf, [])
    ex.each do |k, v|
      if v =~ /^\$pit\[(.+)\]$/
        ex[k] = pit[$1]
      end
    end
    return ex
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
fluent-plugin-config_pit-0.0.2	lib/fluent/plugin/pit.rb
fluent-plugin-config_pit-0.0.1	lib/fluent/plugin/pit.rb