- Add event generator. Can use a canned event message by default or

read a single line from stdin as the event message.

  Intended for performance testing and debugging.

lib/logstash/inputs/generator.rb

@@ -0,0 +1,55 @@
+require "logstash/inputs/base"
+require "logstash/namespace"
+require "socket" # for Socket.gethostname
+
+# Generate random log events.
+#
+# The general intention of this is to test performance of plugins.
+#
+# An event is generated first
+class LogStash::Inputs::Generator < LogStash::Inputs::Base
+
+  config_name "generator"
+
+  plugin_status "experimental"
+
+  # The message string to use in the event.
+  #
+  # If you set this to 'stdin' then this plugin will read a single line from
+  # stdin and use that as the message string for every event.
+  #
+  # Otherwise, this value will be used verbatim as the event message.
+  config :message, :validate => :string, :default => "Hello world!"
+
+  public
+  def register
+    @host = Socket.gethostname
+    @event_count = @logger.metrics.timer(self)
+  end # def register
+
+  def run(queue)
+    number = 0
+    source = "stdin://#{@host}/"
+
+    if @message == "stdin"
+      @logger.info("Generator plugin reading a line from stdin")
+      @message = $stdin.readline
+      @logger.debug("Generator line read complete", :message => @message)
+    end
+
+    while !finished?
+      event = to_event(@message, source)
+      event["sequence"] = number
+      # Time how long each queue push takes.
+      @event_count.time do
+        queue << event
+      end
+      number += 1
+    end # loop
+  end # def run
+
+  public
+  def teardown
+    finished
+  end # def teardown
+end # class LogStash::Inputs::Stdin