class LogStash::Inputs::GoogleCloudStorage::SinceDB::File

Public Class Methods

new(file) click to toggle source
# File lib/logstash/inputs/google_cloud_storage.rb, line 398
def initialize(file)
  @sincedb_path = file
end

Public Instance Methods

newer?(date) click to toggle source
# File lib/logstash/inputs/google_cloud_storage.rb, line 402
def newer?(date)
   date.to_i > read.to_i
end
read() click to toggle source
# File lib/logstash/inputs/google_cloud_storage.rb, line 406
def read
  if ::File.exists?(@sincedb_path)
    content = ::File.read(@sincedb_path).chomp.strip
    # If the file was created but we didn't have the time to write to it
    return content.empty? ? Time.new(0) : Time.parse(content)
  else
    return Time.new(0)
  end
end
write(since = nil) click to toggle source
# File lib/logstash/inputs/google_cloud_storage.rb, line 416
def write(since = nil)
  since = Time.now() if since.nil?
  ::File.open(@sincedb_path, 'w') { |file| file.write(since.to_s) }
end