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