class Fluent::Plugin::EC2MetadataOutput

Attributes

ec2_metadata[R]

Public Instance Methods

process(tag, es) click to toggle source
# File lib/fluent/plugin/out_ec2_metadata.rb, line 20
def process(tag, es)
  tag_parts = tag.split('.')
  es.each { |time, record|
    new_tag, new_record = modify(@output_tag, record, tag, tag_parts)
    router.emit(new_tag, time, new_record)
  }
rescue => e
  log.warn "ec2-metadata: #{e.class} #{e.message} #{e.backtrace.join(', ')}"
end