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