Class: Fluent::Plugin::HerokuHttpInput

Inherits:
HttpInput
  • Object
show all
Defined in:
lib/fluent/plugin/in_heroku_http.rb

Instance Method Summary collapse

Instance Method Details

#parse_params_with_parser(params) ⇒ Object 



16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
 
# 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