class Fluent::FormatOutput

Constants

CONF_KEYS

Public Instance Methods

configure(conf) click to toggle source
Calls superclass method
# File lib/fluent/plugin/out_format.rb, line 10
def configure(conf)
  super

  @fields = {}
  conf.each do |k, v|
    unless CONF_KEYS.include?(k)
      @fields[k] = v
    end
  end
end
emit(tag, es, chain) click to toggle source
# File lib/fluent/plugin/out_format.rb, line 21
def emit(tag, es, chain)
  es.each do |time, record|
    Engine.emit(@tag, time, format_record(record))
  end

  chain.next
end

Private Instance Methods

format_record(record) click to toggle source
# File lib/fluent/plugin/out_format.rb, line 31
def format_record(record)
  result = {}

  if @include_original_fields
    result.merge!(record)
  end

  @fields.each do |k, v|
    result[k] = v.gsub(/%{(.+?)}/).each { record[$1] }
  end

  return result
end