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