Class: Fluent::EventRouter::Pipeline

Inherits:
Object
  • Object
show all
Defined in:
lib/fluent/event_router.rb

Defined Under Namespace

Classes: FilterOptimizer

Instance Method Summary collapse

Constructor Details

#initialize ⇒ Pipeline

Returns a new instance of Pipeline.



142
143
144
145
146
 
# File 'lib/fluent/event_router.rb', line 142

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

Instance Method Details

#add_filter(filter) ⇒ Object 



148
149
150
151
 
# File 'lib/fluent/event_router.rb', line 148

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

#emit_events(tag, es) ⇒ Object 



157
158
159
160
 
# File 'lib/fluent/event_router.rb', line 157

def emit_events(tag, es)
  processed = @optimizer.filter_stream(tag, es)
  @output.emit_events(tag, processed)
end

#set_output(output) ⇒ Object 



153
154
155
 
# File 'lib/fluent/event_router.rb', line 153

def set_output(output)
  @output = output
end