class LogStash::Inputs::Stdin

Public Instance Methods

receive(event) click to toggle source
# File lib/logstash/inputs/stdin.rb, line 14
def receive(event)
  event = LogStash::Event.new({
    "@message" => event,
    "@type" => @type,
    "@tags" => @tags.clone,
  })
  event.source = @url
  @logger.debug(["Got event", event])
  @callback.call(event)
end
register() click to toggle source
# File lib/logstash/inputs/stdin.rb, line 8
def register
  EventMachine::attach($stdin, InputHandler, self)
  @url.host = Socket.gethostname
end