# File lib/fluent/event_router.rb, line 136 def initialize @filters = [] @output = nil @optimizer = FilterOptimizer.new end
# File lib/fluent/event_router.rb, line 142 def add_filter(filter) @filters << filter @optimizer.filters = @filters end
# File lib/fluent/event_router.rb, line 151 def emit_events(tag, es) processed = @optimizer.filter_stream(tag, es) @output.emit_events(tag, processed) end
# File lib/fluent/event_router.rb, line 147 def set_output(output) @output = output end