Sha256: f7a3c9d623c814f11f52cf99e489406644eee4c0b92889dc2630ffed65c66ef0
Contents?: true
Size: 285 Bytes
Versions: 15
Compression:
Stored size: 285 Bytes
Contents
# encoding: utf-8
module LogStash module Inputs
class DeleteCompletedFileHandler
def initialize(watch)
@watch = watch
end
def handle(path)
Pathname.new(path).unlink rescue nil
@watch.watched_files_collection.remove_paths([path])
end
end
end end
Version data entries
15 entries across 15 versions & 1 rubygems