class Fluent::EventRouter::Pipeline

Public Class Methods

new() click to toggle source
# File lib/fluent/event_router.rb, line 164
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 170
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 179
def emit_events(tag, es)
  processed = @optimizer.filter_stream(tag, es)
  @output.emit_events(tag, processed)
end
set_output(output) click to toggle source
# File lib/fluent/event_router.rb, line 175
def set_output(output)
  @output = output
end