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