Parent

Class/Module Index [+]

Quicksearch

Fluent::EventRouter::Pipeline

Public Class Methods

new() click to toggle source
# File lib/fluent/event_router.rb, line 134
def initialize
  @filters = []
  @output = nil
end

Public Instance Methods

add_filter(filter) click to toggle source
# File lib/fluent/event_router.rb, line 139
def add_filter(filter)
  @filters << filter
end
emit(tag, es, chain) click to toggle source
# File lib/fluent/event_router.rb, line 147
def emit(tag, es, chain)
  processed = es
  @filters.each { |filter|
    processed = filter.filter_stream(tag, processed)
  }
  @output.emit(tag, processed, chain)
end
set_output(output) click to toggle source
# File lib/fluent/event_router.rb, line 143
def set_output(output)
  @output = output
end

[Validate]

Generated with the Darkfish Rdoc Generator 2.