class Fluent::Plugin::ParseRequestBodyOutput
Public Instance Methods
configure(conf)
click to toggle source
初始化解析器#
Calls superclass method
# File lib/fluent/plugin/out_parse_request_body.rb, line 42 def configure(conf) super @extractor = Fluent::Plugin::ParseRequestBodyExtractor.new(self, conf) end
filter_record(tag, time, record)
click to toggle source
执行解析工作#
Calls superclass method
# File lib/fluent/plugin/out_parse_request_body.rb, line 52 def filter_record(tag, time, record) record = @extractor.add_query_params_field(record) super(tag, time, record) end
multi_workers_ready?()
click to toggle source
# File lib/fluent/plugin/out_parse_request_body.rb, line 47 def multi_workers_ready? true end
process(tag, es)
click to toggle source
# File lib/fluent/plugin/out_parse_request_body.rb, line 57 def process(tag, es) es.each do |time, record| t = tag.dup filter_record(t, time, record) router.emit(t, time, record) end end