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