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