class LogStash::Inputs::DeleteCompletedFileHandler
Public Class Methods
new(watch)
click to toggle source
# File lib/logstash/inputs/delete_completed_file_handler.rb, line 5 def initialize(watch) @watch = watch end
Public Instance Methods
handle(path)
click to toggle source
# File lib/logstash/inputs/delete_completed_file_handler.rb, line 9 def handle(path) Pathname.new(path).unlink rescue nil @watch.watched_files_collection.remove_paths([path]) end