class Fluent::JsonSerializerFilter

Public Instance Methods

configure(conf) click to toggle source

Load config ————————-

Calls superclass method
# File lib/fluent/plugin/filter_serializer.rb, line 16
def configure(conf)
  super
end
filter(tag, time, record) click to toggle source

Edit Data

# File lib/fluent/plugin/filter_serializer.rb, line 33
def filter(tag, time, record)
  new_record = Hash.new()
  new_record[@field_name] = convert_to_json(record)

  # return
  new_record
end
shutdown() click to toggle source

Shutdown —————————

Calls superclass method
# File lib/fluent/plugin/filter_serializer.rb, line 26
def shutdown
  super
end
start() click to toggle source

Start ——————————-

Calls superclass method
# File lib/fluent/plugin/filter_serializer.rb, line 21
def start
  super
end

Private Instance Methods

convert_to_json(record) click to toggle source

Convert record to json

# File lib/fluent/plugin/filter_serializer.rb, line 45
def convert_to_json(record)
  Oj.dump(record, :mode => :compat)
end