class LogStash::Inputs::File::Reader
Public Class Methods
new(path, receiver)
click to toggle source
Calls superclass method
# File lib/logstash/inputs/file.rb, line 40 def initialize(path, receiver) super(path) @receiver = receiver @buffer = BufferedTokenizer.new # From eventmachine end
Public Instance Methods
receive_data(data)
click to toggle source
# File lib/logstash/inputs/file.rb, line 46 def receive_data(data) # TODO(2.0): Support multiline log data @buffer.extract(data).each do |line| @receiver.receive(self, line) end end