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