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