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