class LogStash::Inputs::Reqsample
Generate randomized webserver log strings.
Logs can be generated at once in bulk, or streamed over time.
Public Instance Methods
register()
click to toggle source
# File lib/logstash/inputs/reqsample.rb, line 43 def register @host = Socket.gethostname @generator = ::ReqSample::Generator.new @stdev @production_options = { :count => @count, :format => @format, :sleep => @stream, :truncate => @truncate, :peak => Chronic.parse(@peak) } end
run(queue)
click to toggle source
# File lib/logstash/inputs/reqsample.rb, line 55 def run(queue) @generator.produce(@production_options).lazy.each do |log| break if stop? event = LogStash::Event.new('message' => log, 'host' => @host) decorate(event) queue << event end # produce end