class Fluent::EventRouter::Pipeline
Public Class Methods
new()
click to toggle source
# File lib/fluent/event_router.rb, line 177 def initialize @filters = [] @output = nil @optimizer = FilterOptimizer.new end
Public Instance Methods
add_filter(filter)
click to toggle source
# File lib/fluent/event_router.rb, line 183 def add_filter(filter) @filters << filter @optimizer.filters = @filters end
emit_events(tag, es)
click to toggle source
# File lib/fluent/event_router.rb, line 192 def emit_events(tag, es) processed = @optimizer.filter_stream(tag, es) begin @output.emit_events(tag, processed) rescue => e raise OutputError.new(e, processed) end end
set_output(output)
click to toggle source
# File lib/fluent/event_router.rb, line 188 def set_output(output) @output = output end