# File lib/fluent/event_router.rb, line 136 def initialize @filters = [] @output = nil end
# File lib/fluent/event_router.rb, line 141 def add_filter(filter) @filters << filter end
# File lib/fluent/event_router.rb, line 149 def emit(tag, es, chain) processed = es @filters.each { |filter| processed = filter.filter_stream(tag, processed) } @output.emit(tag, processed, chain) end
# File lib/fluent/event_router.rb, line 145 def set_output(output) @output = output end