Object
# File lib/fluent/event_router.rb, line 134 def initialize @filters = [] @output = nil end
# File lib/fluent/event_router.rb, line 139 def add_filter(filter) @filters << filter end
# File lib/fluent/event_router.rb, line 147 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 143 def set_output(output) @output = output end
[Validate]
Generated with the Darkfish Rdoc Generator 2.