Class: Fluent::EventRouter::Pipeline::FilterOptimizer

Inherits:

Object

• Object
• Fluent::EventRouter::Pipeline::FilterOptimizer

Defined in:

lib/fluent/event_router.rb

Instance Method Summary

• #filter_stream(tag, es) ⇒ Object
• #filters=(filters) ⇒ Object
• #initialize(filters = []) ⇒ FilterOptimizer constructor

  A new instance of FilterOptimizer.

Constructor Details

#initialize(filters = []) ⇒ FilterOptimizer

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

def initialize(filters = [])
  @filters = filters
  @optimizable = nil
end

Instance Method Details

#filter_stream(tag, es) ⇒ Object

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

def filter_stream(tag, es)
  if optimizable?
    optimized_filter_stream(tag, es)
  else
    @filters.reduce(es) { |acc, filter| filter.filter_stream(tag, acc) }
  end
end

#filters=(filters) ⇒ Object

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

def filters=(filters)
  @filters = filters
  reset_optimization
end