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