class Fluent::Plugin::ExtractQueryParamsOutput
Public Instance Methods
configure(conf)
click to toggle source
Calls superclass method
# File lib/fluent/plugin/out_extract_query_params.rb, line 34 def configure(conf) super @extractor = Fluent::Plugin::QueryParamsExtractor.new(self, conf) end
filter_record(tag, time, record)
click to toggle source
Calls superclass method
# File lib/fluent/plugin/out_extract_query_params.rb, line 43 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_extract_query_params.rb, line 39 def multi_workers_ready? true end
process(tag, es)
click to toggle source
# File lib/fluent/plugin/out_extract_query_params.rb, line 48 def process(tag, es) es.each do |time, record| t = tag.dup filter_record(t, time, record) router.emit(t, time, record) end end