Class: LogStash::Inputs::Reqsample

Inherits:
Base
  • Object
show all
Defined in:
lib/logstash/inputs/reqsample.rb

Overview

Generate randomized webserver log strings.

Logs can be generated at once in bulk, or streamed over time.

Instance Method Summary collapse

Instance Method Details

#register ⇒ Object 



43
44
45
46
47
48
49
50
51
52
53
 
# 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) ⇒ Object

def register



55
56
57
58
59
60
61
62
 
# File 'lib/logstash/inputs/reqsample.rb', line 55

def run(queue)
  @generator.produce(@production_options).lazy do |log|
    break if stop?
    event = LogStash::Event.new('message' => log, 'host' => @host)
    decorate(event)
    queue << event
  end # produce
end