github-mirrors/logstash
1
0
Fork 0
mirror of https://github.com/elastic/logstash.git synced 2025-04-25 07:07:54 -04:00
Code Issues Projects Releases Packages Wiki Activity

add hooks for after filter

Browse source
This commit is contained in:
Nick Ethier 2013-04-09 14:59:47 -06:00 • committed by Jordan Sissel
parent 83afe07707
commit cc8b9214df
1 changed files with 13 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

14
lib/logstash/filterworker.rb
View file

@ -9,6 +9,7 @@ class LogStash::FilterWorker < LogStash::Plugin
include Stud
attr_accessor :logger
attr_accessor :filters
attr_reader :after_filter
Exceptions = [Exception]
Exceptions << java.lang.Exception if RUBY_ENGINE == "jruby"
@ -20,6 +21,13 @@ class LogStash::FilterWorker < LogStash::Plugin
@shutdown_requested = false
end # def initialize
#This block is called after each filter is done on an event.
#The filtered event and filter class name is passed to the block.
#This could be used to add metrics in the future?
def after_filter(&block)
@after_filter = block
end
def run
# TODO(sissel): Run a flusher thread for each plugin requesting flushes
# > It seems reasonable that you could want a multiline filter to flush
@ -47,7 +55,10 @@ class LogStash::FilterWorker < LogStash::Plugin
# Filter any events generated so far in this flush.
events.each do |event|
# TODO(sissel): watchdog on flush filtration?
filter.filter(event) unless event.cancelled?
unless event.cancelled?
filter.filter(event)
@after_filter.call(event,filter) unless @after_filter.nil?
end
end
# TODO(sissel): watchdog on flushes?
@ -99,6 +110,7 @@ class LogStash::FilterWorker < LogStash::Plugin
:filter => filter.class)
break
end
@after_filter.call(event,filter) unless @after_filter.nil?
end # @filters.each
@logger.debug? and @logger.debug("Event finished filtering", :event => event,