class Fluent::ReemitOutput::V14EventRouter
Almost same as V12EventRouter
but (1) it must call emit_events instead of emit (2) Filter class is Fluent::Plugin::Filter instead of Fluent::Filter
Public Instance Methods
emit_stream(tag, es)
click to toggle source
copy from fluentd
# File lib/fluent/plugin/out_reemit/v14_event_router.rb, line 14 def emit_stream(tag, es) match(tag).emit_events(tag, es) rescue => e @emit_error_handler.handle_emits_error(tag, es, e) end
filter_class()
click to toggle source
# File lib/fluent/plugin/out_reemit/v14_event_router.rb, line 9 def filter_class ::Fluent::Plugin::Filter end