class Fluent::Plugin::ForceEncodingFilter
Public Instance Methods
configure(conf)
click to toggle source
Calls superclass method
# File lib/fluent/plugin/filter_force_encoding.rb, line 32 def configure(conf) super @accessors = @elements.map do |element| [record_accessor_create(element.key), element.encoding] end end
filter(tag, time, record)
click to toggle source
# File lib/fluent/plugin/filter_force_encoding.rb, line 40 def filter(tag, time, record) @accessors.each do |accessor, encoding| raw_value = accessor.call(record) value = raw_value&.force_encoding(encoding) || raw_value accessor.set(record, value) end record end