Module: Fluent::RecordFilterMixin

Included in:
HandleTagNameMixin, SetTagKeyMixin, SetTimeKeyMixin
Defined in:
lib/fluent/mixin.rb

Instance Method Summary collapse

Instance Method Details

#filter_record(tag, time, record) ⇒ Object 



84
85
 
# File 'lib/fluent/mixin.rb', line 84

def filter_record(tag, time, record)
end

#format_stream(tag, es) ⇒ Object 



87
88
89
90
91
92
93
94
95
 
# File 'lib/fluent/mixin.rb', line 87

def format_stream(tag, es)
  out = ''
  es.each {|time,record|
    tag_temp = tag.dup
    filter_record(tag_temp, time, record)
    out << format(tag_temp, time, record)
  }
  out
end