class Fluent::Plugin::HerokuHttpInput
Public Instance Methods
parse_params_with_parser(params)
click to toggle source
Calls superclass method
# File lib/fluent/plugin/in_heroku_http.rb, line 16 def parse_params_with_parser(params) drain_id = params['HTTP_LOGPLEX_DRAIN_TOKEN'] if @drain_ids.nil? || @drain_ids.include?(drain_id) _time, records = super records.each do |record| record['drain_id'] = drain_id end [_time, records] else log.warn("drain_id #{drain_id.inspect} is not in #{@drain_ids.inspect}.") [nil, []] end end