Class: LogStash::Inputs::File::Reader

Inherits:

EventMachine::FileTail

• Object
• EventMachine::FileTail
• LogStash::Inputs::File::Reader

Defined in:

lib/logstash/inputs/file.rb

Instance Method Summary

• #initialize(path, receiver) ⇒ Reader constructor

  A new instance of Reader.

• #receive_data(data) ⇒ Object

Constructor Details

#initialize(path, receiver) ⇒ Reader

Returns a new instance of Reader.

# File 'lib/logstash/inputs/file.rb', line 40

def initialize(path, receiver)
  super(path)
  @receiver = receiver
  @buffer = BufferedTokenizer.new  # From eventmachine
end

Instance Method Details

#receive_data(data) ⇒ Object

# 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