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