class LogStash::Filters::Inspection
Adds 'inspection' tag for defined interval
Public Instance Methods
filter(event)
click to toggle source
# File lib/logstash/filters/inspection.rb, line 25 def filter(event) check_inspection_interval(event) end
register()
click to toggle source
# File lib/logstash/filters/inspection.rb, line 18 def register now = Time.now @last_inspection_run = now end
Private Instance Methods
check_inspection_interval(event)
click to toggle source
# File lib/logstash/filters/inspection.rb, line 30 def check_inspection_interval(event) now = Time.now return unless now - @last_inspection_run >= @inspection_interval run_inspections(event) @last_inspection_run = now end
run_inspections(event)
click to toggle source
# File lib/logstash/filters/inspection.rb, line 39 def run_inspections(event) event.tag(@inspection_tag) end