Contents

# encoding: utf-8
require "logstash/inputs/base"
require "logstash/namespace"
require "socket" # for Socket.gethostname

# Read events from standard input.
#
# By default, each event is assumed to be one line. If you
# want to join lines, you'll want to use the multiline filter.
class LogStash::Inputs::Stdin < LogStash::Inputs::Base
  config_name "stdin"

  default :codec, "line"

  public
  def register
    @host = Socket.gethostname
    fix_streaming_codecs
  end # def register

  def run(queue) 
    while true
      begin
        # Based on some testing, there is no way to interrupt an IO.sysread nor
        # IO.select call in JRuby. Bummer :(
        data = $stdin.sysread(16384)
        @codec.decode(data) do |event|
          decorate(event)
          event["host"] = @host if !event.include?("host")
          queue << event
        end
      rescue IOError, EOFError, LogStash::ShutdownSignal
        # stdin closed or a requested shutdown
        break
      end
    end # while true
    finished
  end # def run

  public
  def teardown
    @logger.debug("stdin shutting down.")
    $stdin.close rescue nil
    finished
  end # def teardown
end # class LogStash::Inputs::Stdin

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
logstash-input-stdin-0.1.5	lib/logstash/inputs/stdin.rb
logstash-input-stdin-0.1.4	lib/logstash/inputs/stdin.rb
logstash-input-stdin-0.1.3	lib/logstash/inputs/stdin.rb
logstash-input-stdin-0.1.2	lib/logstash/inputs/stdin.rb