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