Class: Fluent::EC2MetadataOutput

Inherits:
Output
  • Object
show all
Includes:
EC2Metadata
Defined in:
lib/fluent/plugin/out_ec2_metadata.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Methods included from EC2Metadata

#configure, #initialize

Instance Attribute Details

#ec2_metadata ⇒ Object (readonly)

Returns the value of attribute ec2_metadata.



23
24
25
 
# File 'lib/fluent/plugin/out_ec2_metadata.rb', line 23

def ec2_metadata
  @ec2_metadata
end

Instance Method Details

#emit(tag, es, chain) ⇒ Object 



25
26
27
28
29
30
31
32
33
34
 
# File 'lib/fluent/plugin/out_ec2_metadata.rb', line 25

def emit(tag, es, chain)
  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)
  }
  chain.next
rescue => e
  log.warn "ec2-metadata: #{e.class} #{e.message} #{e.backtrace.join(', ')}"
end