Class: Fluent::EventRouter::Pipeline

Inherits:

Object

• Object
• Fluent::EventRouter::Pipeline

Defined in:

lib/fluent/event_router.rb

Defined Under Namespace

Classes: FilterOptimizer, OutputError

Instance Method Summary

• #add_filter(filter) ⇒ Object
• #emit_events(tag, es) ⇒ Object
• #initialize ⇒ Pipeline constructor

  A new instance of Pipeline.

• #set_output(output) ⇒ Object

Constructor Details

#initialize ⇒ Pipeline

Returns a new instance of Pipeline.

# File 'lib/fluent/event_router.rb', line 177

def initialize
  @filters = []
  @output = nil
  @optimizer = FilterOptimizer.new
end

Instance Method Details

#add_filter(filter) ⇒ Object

# File 'lib/fluent/event_router.rb', line 183

def add_filter(filter)
  @filters << filter
  @optimizer.filters = @filters
end

#emit_events(tag, es) ⇒ Object

# 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) ⇒ Object

# File 'lib/fluent/event_router.rb', line 188

def set_output(output)
  @output = output
end