Contents

# encoding: utf-8

module FileWatch module TailMode module Handlers
  class Shrink < Base
    def handle_specifically(watched_file)
      add_or_update_sincedb_collection(watched_file)
      watched_file.file_seek(watched_file.bytes_read)
      logger.debug("reading to eof: #{watched_file.path}")
      read_to_eof(watched_file)
    end

    def update_existing_specifically(watched_file, sincedb_value)
      # we have a match but size is smaller
      # set all to zero
      logger.debug("update_existing_specifically: #{watched_file.path}: was truncated seeking to beginning")
      watched_file.update_bytes_read(0) if watched_file.bytes_read != 0
      sincedb_value.update_position(0)
    end
  end
end end end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
logstash-input-file-4.1.3	lib/filewatch/tail_mode/handlers/shrink.rb
logstash-input-file-4.1.2	lib/filewatch/tail_mode/handlers/shrink.rb
logstash-input-file-4.1.1	lib/filewatch/tail_mode/handlers/shrink.rb
logstash-input-file-4.1.0	lib/filewatch/tail_mode/handlers/shrink.rb