Class: Fluent::RecordSerializerOutput

Inherits:
Output
  • Object
show all
Includes:
RecordSerializer, SetTagKeyMixin
Defined in:
lib/fluent/plugin/out_record_serializer.rb

Instance Method Summary collapse

Methods included from RecordSerializer

#serialize_record

Instance Method Details

#emit(tag, es, chain) ⇒ Object 



18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
 
# File 'lib/fluent/plugin/out_record_serializer.rb', line 18

def emit(tag, es, chain)
  es.each { |time, record|
    begin
      serialized_record = serialize_record(@format, record)
    rescue => e
      $log.warn "serialize error: #{e.message}"
      next
    end

    router.emit(@tag, time, {
      'tag' => @tag,
      @field_name => serialized_record
    })
  }

  chain.next
end