Sha256: f000fad88c02ccba5e13938ffaf32003fe7309af521be9648849f165c6f54658
Contents?: true
Size: 516 Bytes
Versions: 30
Compression:
Stored size: 516 Bytes
Contents
# encoding: utf-8
require "logstash/util/loggable"
require_relative "read_mode/processor"
module FileWatch
class ObservingRead
include LogStash::Util::Loggable
include ObservingBase
def subscribe(observer)
# observer here is the file input
watch.subscribe(observer, sincedb_collection)
sincedb_collection.write("read mode subscribe complete - shutting down")
end
private
def build_specific_processor(settings)
ReadMode::Processor.new(settings)
end
end
end
Version data entries
30 entries across 30 versions & 1 rubygems