module Fluent::RecordFilterMixin
Public Instance Methods
filter_record(tag, time, record)
click to toggle source
# File lib/fluent/mixin.rb, line 83 def filter_record(tag, time, record) end
format_stream(tag, es)
click to toggle source
# File lib/fluent/mixin.rb, line 86 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