Module: Fluent::Compat::RecordFilterMixin
- Included in:
- HandleTagNameMixin, SetTagKeyMixin, SetTimeKeyMixin
- Defined in:
- lib/fluent/compat/record_filter_mixin.rb
Instance Method Summary collapse
Instance Method Details
#filter_record(tag, time, record) ⇒ Object
20 21 |
# File 'lib/fluent/compat/record_filter_mixin.rb', line 20 def filter_record(tag, time, record) end |
#format_stream(tag, es) ⇒ Object
23 24 25 26 27 28 29 30 31 |
# File 'lib/fluent/compat/record_filter_mixin.rb', line 23 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 |